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 一起使用。