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 文件