Salesforce 到 GCS 运算符¶

先决条件任务¶

要使用这些运算符，您必须执行以下操作：

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

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

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

SalesforceToGcsOperator¶

使用 SalesforceToGcsOperator 执行 Salesforce 查询以获取数据并将其加载到 GCS。

tests/system/google/cloud/gcs/example_salesforce_to_gcs.py

    gcs_upload_task = SalesforceToGcsOperator(
        query=QUERY,
        include_deleted=True,
        bucket_name=BUCKET_NAME,
        object_name=GCS_OBJ_PATH,
        export_format="csv",
        coerce_to_timestamp=False,
        record_time_added=False,
        task_id="upload_to_gcs",
        salesforce_conn_id="salesforce_conn_id",
    )

参考¶

欲了解更多信息，请参阅

Simple Salesforce 文档