SalesforceBulkOperator
SalesforceExecute a Salesforce Bulk API and pushes results to xcom.
Access Instructions
Install the Salesforce provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
operationRequiredBulk operation to be performed Available operations are in [‘insert’, ‘update’, ‘upsert’, ‘delete’, ‘hard_delete’]
object_nameRequiredThe name of the Salesforce object
payloadRequiredlist of dict to be passed as a batch
external_id_fieldunique identifier field for upsert operations
batch_sizenumber of records to assign for each batch in the job
use_serialProcess batches in serial mode
salesforce_conn_idThe Salesforce Connection id.
Documentation
Execute a Salesforce Bulk API and pushes results to xcom.
See also
For more information on how to use this operator, take a look at the guide: SalesforceBulkOperator