SQL 至 Google 試算表傳輸運算子¶
使用 Google 試算表,每個人都可以同時在同一個試算表中協作。使用公式、函數和格式化選項來節省時間並簡化常見的試算表任務。
先決條件任務¶
要使用這些運算子,您必須完成幾件事
使用 Cloud Console 選擇或建立一個雲端平台專案。
為您的專案啟用計費功能,如 Google Cloud 文件 中所述。
啟用 API,如 Cloud Console 文件 中所述。
透過 pip 安裝 API 程式庫。
pip install 'apache-airflow[google]'詳細資訊請參閱 安裝。
從 SQL 上傳資料至 Google 試算表¶
要使用 SQL 從資料庫上傳資料至 Google 試算表,您可以使用 SQLToGoogleSheetsOperator
。
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
一起使用。