airflow.providers.salesforce.operators.salesforce_apex_rest¶

类¶

SalesforceApexRestOperator

执行 APEX Rest API 操作。

模块内容¶

class airflow.providers.salesforce.operators.salesforce_apex_rest.SalesforceApexRestOperator(*, endpoint, method='GET', payload, salesforce_conn_id='salesforce_default', **kwargs)[source]¶

基础: airflow.models.BaseOperator

执行 APEX Rest API 操作。

另请参阅

有关如何使用此操作符的更多信息，请参阅以下指南： SalesforceApexRestOperator

参数:

endpoint (str) – 请求的 REST 端点。
method (str) – 请求的 HTTP 方法（默认为 GET）
payload (dict) – 在 POST / PUT 请求中发送的参数字典
salesforce_conn_id (str) – Salesforce 连接 ID。

endpoint[source]¶

method = 'GET'[source]¶

payload[source]¶

salesforce_conn_id = 'salesforce_default'[source]¶

execute(context)[source]¶

向 APEX REST 端点发出 HTTP 请求并将结果推送到 xcom。

参数:: context (airflow.sdk.definitions.context.Context) – 执行期间的任务上下文。
返回:: Apex 响应
返回类型:: 字典