Postgres 到 Google Cloud Storage 操作符¶

Google Cloud Storage (GCS) 服务用于存储来自各种应用程序的大型数据。此页面显示如何将数据从 Postgres 复制到 GCS。

先决条件任务¶

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

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

为您的项目启用结算，如 Google Cloud 文档中所述。

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

PostgresToGCSOperator¶

PostgresToGCSOperator 允许您将数据从 Postgres 数据库上传到 GCS。

当您使用此操作符时，您可以选择将上传的数据压缩为 gzip 格式。

以下是使用此操作符将数据上传到 GCS 的示例。

tests/system/google/cloud/transfers/example_postgres_to_gcs.py[源代码]

    postgres_to_gcs = PostgresToGCSOperator(
        task_id="postgres_to_gcs",
        postgres_conn_id=CONNECTION_ID,
        sql=SQL_SELECT,
        bucket=BUCKET_NAME,
        filename=FILE_NAME,
        export_format="csv",
    )

参考¶

有关更多信息，请查看： * Google Cloud Storage 文档