airflow.providers.salesforce.operators.bulk¶
模組內容¶
類別¶
執行 Salesforce Bulk API 並將結果推送到 xcom。 |
- class airflow.providers.salesforce.operators.bulk.SalesforceBulkOperator(*, operation, object_name, payload, external_id_field='Id', batch_size=10000, use_serial=False, salesforce_conn_id='salesforce_default', **kwargs)[原始碼]¶
基底類別:
airflow.models.BaseOperator執行 Salesforce Bulk API 並將結果推送到 xcom。
參見
關於如何使用此 operator 的更多資訊，請查看指南： SalesforceBulkOperator
- 參數
operation (typing_extensions.Literal[insert, update, upsert, delete, hard_delete]) – 要執行的 Bulk 操作。可用操作為 [‘insert’, ‘update’, ‘upsert’, ‘delete’, ‘hard_delete’]
object_name (str) – Salesforce 物件的名稱
payload (list) – 要作為批次傳遞的字典列表
external_id_field (str) – upsert 操作的唯一識別欄位
batch_size (int) – 每個 job 中批次處理的記錄數量
use_serial (bool) – 以序列模式處理批次
salesforce_conn_id (str) – Salesforce 連線 ID。