Google Cloud Storage 到 Google Sheets 传输操作符¶

Google 有一项服务 Google Cloud Storage。此服务用于存储来自各种应用程序的大量数据。

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

先决条件任务¶

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

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

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

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

从 GCS 上传数据到 Google Sheets¶

要将数据从 Google Cloud Storage 上传到 Google Spreadsheet，您可以使用 GCSToGoogleSheetsOperator。

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

upload_gcs_to_sheet = GCSToGoogleSheetsOperator(
    task_id="upload_gcs_to_sheet",
    bucket_name=BUCKET_NAME,
    object_name="{{ task_instance.xcom_pull('upload_sheet_to_gcs')[0] }}",
    spreadsheet_id="{{ task_instance.xcom_pull(task_ids='create_spreadsheet', "
    "key='spreadsheet_id') }}",
    gcp_conn_id=CONNECTION_ID,
)

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