Google Sheets 操作符¶

最新版本的 Sheets API 允许开发者以编程方式

读取和写入数据
格式化文本和数字
构建数据透视表
强制单元格验证
设置冻结行
调整列大小
应用公式
创建图表…等等！

更多信息请查看官方文档。

先决条件任务¶

要使用这些操作符，您必须执行以下几项操作

使用 Cloud Console 选择或创建 Cloud Platform 项目。

按照 Google Cloud 文档中的说明，为您的项目启用结算功能。

按照 Cloud Console 文档中的说明，启用 API。
通过 pip 安装 API 库。
pip install 'apache-airflow[google]'
详细信息请参考安装。
设置 Google Cloud 连接.

创建电子表格¶

要创建新的电子表格，您可以使用 GoogleSheetsCreateSpreadsheetOperator。

tests/system/google/cloud/gcs/example_sheets.py[源代码]

create_spreadsheet = GoogleSheetsCreateSpreadsheetOperator(
    task_id="create_spreadsheet", spreadsheet=SPREADSHEET, gcp_conn_id=CONNECTION_ID
)

您可以使用 Jinja 模板处理 spreadsheet, impersonation_chain。

要获取新创建的电子表格的 URL，请使用 XCom 值

tests/system/google/cloud/gcs/example_sheets.py[源代码]

print_spreadsheet_url = BashOperator(
    task_id="print_spreadsheet_url",
    bash_command=f"echo {XComArg(create_spreadsheet, key='spreadsheet_url')}",
)