airflow.providers.salesforce.operators.salesforce_apex_rest

Module Contents

Classes

SalesforceApexRestOperator

Execute a APEX Rest API action
class airflow.providers.salesforce.operators.salesforce_apex_rest.SalesforceApexRestOperator(*, endpoint, method='GET', payload, salesforce_conn_id='salesforce_default', **kwargs)[source]

Bases: airflow.models.BaseOperator

Execute a APEX Rest API action

See also

For more information on how to use this operator, take a look at the guide: SalesforceApexRestOperator

Parameters

  • endpoint (str) – The REST endpoint for the request.

  • method (str) – HTTP method for the request (default GET)

  • payload (dict) – A dict of parameters to send in a POST / PUT request

  • salesforce_conn_id (str) – The Salesforce Connection id.

execute(context)[source]

Makes an HTTP request to an APEX REST endpoint and pushes results to xcom. :param context: The task context during execution. :return: Apex response

Was this entry helpful?