SQL 到 Google Sheets 传输操作符¶

借助 Google Sheets，每个人都可以同时在同一个电子表格中协作。使用公式、函数和格式选项来节省时间并简化常见的电子表格任务。

先决任务¶

要使用这些操作符，您需要执行一些步骤

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

为您的项目启用结算，详情请参阅 Google Cloud 文档。

启用 API，详情请参阅 Cloud Console 文档。
通过 pip 安装 API 库。
pip install 'apache-airflow[google]'
详细信息请参阅安装。
设置 Google Cloud 连接.

将数据从 SQL 上传到 Google Sheets¶

要使用 SQL 将数据从数据库上传到 Google Spreadsheet，您可以使用 SQLToGoogleSheetsOperator。

tests/system/google/cloud/sql_to_sheets/example_sql_to_sheets.py

upload_sql_to_sheet = SQLToGoogleSheetsOperator(
    task_id="upload_sql_to_sheet",
    sql=SQL_SELECT,
    sql_conn_id=CONNECTION_ID,
    database=DB_NAME,
    spreadsheet_id="{{ task_instance.xcom_pull(task_ids='create_spreadsheet', key='spreadsheet_id') }}",
    gcp_conn_id=SHEETS_CONNECTION_ID,
)

您可以将 Jinja 模板与 sql, spreadsheet_id, spreadsheet_range, impersonation_chain 一起使用。