airflow.providers.salesforce.operators.bulk

SalesforceBulkOperator

执行 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

available_operations = ('insert', 'update', 'upsert', 'delete', 'hard_delete')[source]
operation[source]
object_name[source]
payload[source]
external_id_field = 'Id'[source]
batch_size = 10000[source]
use_serial = False[source]
salesforce_conn_id = 'salesforce_default'[source]
execute(context)[source]

向 Salesforce Bulk API 发起 HTTP 请求。

参数:

context (airflow.sdk.definitions.context.Context) – 执行期间的任务上下文。

返回:

如果 do_xcom_push 为 True,则返回 API 响应

此条目有帮助吗?