如何在Azure的ADF管道中调用Webhook服务

以下是在ADF管道中调用Webhook服务的具体实现流程：

1. 添加Web活动到管道 #

在ADF管道画布中，从左侧活动面板的「General」分类里拖拽Web活动到画布，给活动命名（比如CallWebhookService）。

2. 配置Webhook请求基础信息 #

进入Web活动的Settings选项卡：

• Method：选择POST（绝大多数Webhook服务要求POST请求）。
• URL：填入Webhook服务的端点地址；如果需要动态传入URL，可使用ADF参数，比如@pipeline().parameters.WebhookEndpoint。
• Headers：根据Webhook要求添加请求头，常见的如Content-Type: application/json；若需API密钥认证，可添加x-api-key: {your-api-key}这类头信息。

3. 构造请求体（Body） #

如果Webhook需要接收请求体数据，在Body区域输入符合要求的JSON内容：

• 带动态内容的示例：{"eventType": "adf_pipeline_triggered", "payload": {"pipelineName": "@pipeline().PipelineName", "runId": "@pipeline().RunId"}}
• 注意：使用动态表达式需以@开头，确保格式符合ADF语法规范。

4. 配置回调等待（可选） #

若需等待Webhook服务的回调确认执行结果，勾选Wait for completion：

• Callback URL：ADF会自动生成回调URL，用于接收Webhook响应，无需手动填写。
• Timeout：设置等待回调的超时时间（比如30分钟），超时后活动会自动终止。

5. 配置认证（按需） #

如果Webhook服务需要认证，切换到Authentication选项卡，选择对应认证方式：

• Basic authentication：直接输入用户名和密码。
• OAuth2：选择已配置的Azure AD服务主体或托管标识，前提是Webhook服务支持OAuth2认证。
• API Key：也可直接在Headers中配置，如步骤2所述。

6. 测试与验证 #

保存管道后触发运行，进入ADF的Monitor面板查看Web活动执行状态：

• 检查响应状态码（比如202表示请求已被Webhook接收，200表示处理完成）。
• 查看输入输出日志，确认请求内容和Webhook返回的响应是否符合预期。

内容的提问来源于stack exchange，提问作者RK.