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 響應