`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]) – 要执行的批量操作。可用的操作在 [‘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。

available_operations = ('insert', 'update', 'upsert', 'delete', 'hard_delete')[source]¶

execute(context)[source]¶

向 Salesforce Bulk API 发出 HTTP 请求。

参数: context (airflow.utils.context.Context) – 执行期间的任务上下文。
返回: 如果 do_xcom_push 为 True，则返回 API 响应

airflow.providers.salesforce.operators.bulk¶

模块内容¶

类¶

`airflow.providers.salesforce.operators.bulk`¶