airflow.providers.salesforce.operators.salesforce_apex_rest

Module Contents

class airflow.providers.salesforce.operators.salesforce_apex_rest.SalesforceApexRestOperator(*, endpoint: str, method: str = 'GET', payload: dict = None, salesforce_conn_id: str = '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 (str) – A dict of parameters to send in a POST / PUT request

  • salesforce_conn_id (str) – The Salesforce Connection id.

execute(self, context: dict)[source]

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

Was this entry helpful?