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)[source]¶
基类:
airflow.models.BaseOperator
执行 Salesforce Bulk API 操作并将结果推送至 xcom。
参见
有关如何使用此操作符的更多信息,请参阅指南: 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) – 作业中每个批次分配的记录数
use_serial (bool) – 以串行模式处理批次
salesforce_conn_id (str) – Salesforce 连接 ID。请参见 Salesforce Connection id。