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(self, 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 :rtype: dict

Was this entry helpful?