Salesforce 到 GCS 运算符¶

先决任务¶

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

使用 Cloud 控制台选择或创建 Cloud Platform 项目。

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

启用 API，如 Cloud 控制台文档中所述。
通过 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 文档