Salesforce 到 GCS 操作符¶

先决条件任务¶

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

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

按照 Google Cloud 文档中的说明，为您的项目启用结算。

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

SalesforceToGcsOperator¶

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

airflow/providers/google/cloud/example_dags/example_salesforce_to_gcs.py[源代码]

    gcs_upload_task = SalesforceToGcsOperator(
        query=QUERY,
        include_deleted=True,
        bucket_name=GCS_BUCKET,
        object_name=GCS_OBJ_PATH,
        salesforce_conn_id=SALESFORCE_CONN_ID,
        export_format="csv",
        coerce_to_timestamp=False,
        record_time_added=False,
        gcp_conn_id=GCS_CONN_ID,
        task_id="upload_to_gcs",
        dag=dag,
    )

参考¶

有关更多信息，请参阅：

Simple Salesforce 文档