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 响应