如何从ADF Webhook活动向Azure Automation Python3 Runbook传参

整个场景不需要额外搭建中间中转服务，参数传递的核心逻辑是：Azure Automation为每个托管Runbook生成带鉴权密钥的Webhook触发端点，ADF管道内的Webhook活动通过POST请求调用该端点，所有自定义业务参数随请求体发送，Runbook端在内置的Webhook上下文对象中解析提取这些参数，完成跨服务的值传递。

第一步：配置Azure Automation侧基础能力 #

• 确认已创建好目标Azure Automation账户，且上传了待触发的Python3版本Runbook
• 进入对应Python3 Runbook的编辑页面，切换到「Webhook」配置面板，点击新增Webhook：
  • 选择“创建新Webhook”，自定义Webhook名称，按照业务规则设置过期时间
  • 重点留存生成的完整Webhook调用URL：这个URL里的鉴权密钥部分只会在创建完成时完整展示一次，后续再次进入配置页无法看到全量值，必须提前复制保存
  • 选择匹配的Python3运行环境，保存Webhook配置
• 调整Runbook脚本的参数解析逻辑：Azure Automation通过Webhook触发时，不会把请求体里的参数直接映射为Runbook的入口参数，所有请求上下文都会封装在名为WebhookData的内置对象中，需要在脚本开头添加解析代码，示例：

import json

# 获取Webhook触发的内置上下文对象
webhook_ctx = params.get("WebhookData", {})
# 解析POST请求体的JSON内容
req_body = json.loads(webhook_ctx.get("RequestBody", "{}"))

# 提取自定义传入的业务参数，可根据实际业务调整字段名
input_table = req_body.get("target_table", "")
run_batch_id = req_body.get("batch_id", "")

第二步：配置ADF管道内的Webhook活动 #

• 在ADF管道画布的活动列表中找到「Webhook」活动，拖拽到流程对应节点，配置活动的超时时间、重试策略等基础运行规则
• 填写Webhook活动的核心请求配置：
  • URL栏粘贴之前从Azure Automation侧留存的完整Webhook地址
  • 请求方法固定选择POST（Azure Automation的Webhook端点不支持GET请求）
  • 打开高级设置中的「使用请求体」开关，在请求体编辑框中以标准JSON格式组装要传递的参数，支持直接动态引用ADF管道参数、上游活动输出值，示例：

{
  "target_table": "@pipeline().parameters.source_dataset",
  "batch_id": "@pipeline().RunId"
}

• 在请求头配置中手动添加Content-Type: application/json，否则接收端会无法正确解析JSON格式的参数

第三步：联调验证与常见注意点 #

• 单独触发ADF管道的Webhook活动节点，打开Azure Automation对应的Runbook作业日志，确认脚本内打印的参数值和ADF侧发送的内容一致
• 易踩坑提醒：
  • 不要把自定义业务参数拼在Webhook URL的查询参数里，Azure Automation的Webhook触发逻辑不会自动解析URL查询串的参数，所有自定义参数必须放在POST请求体中
  • 组装JSON请求体时，要注意特殊字符的转义，避免出现格式错误导致参数解析失败
  • Webhook URL的鉴权部分等同于Runbook的运行权限，不要把完整URL泄露到公开代码仓库、非受控的日志位置

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