如何在AWS中创建Webhook监听器接收Azure Runbook推送的数据

你不需要找专门适配Azure到AWS的转发教程，本质就是普通的HTTP POST请求对接，和转发到Slack/GitHub的逻辑没有区别，只是接收端换成你自己搭建的AWS HTTP端点即可，具体实现分两步：

第一步：搭建AWS侧Webhook监听器 #

不用找第三方集成模板，直接用基础Lambda+HTTP触发即可：

• 新建自定义Lambda函数，运行时选你熟悉的语言即可（Python/Node.js/PowerShell都支持）
• 给Lambda配置公网HTTP触发入口：测试阶段直接开Lambda函数URL最方便，生产环境建议挂API Gateway，配置POST方法允许公网访问，可按需加API Key做请求鉴权
• Lambda核心逻辑只需要解析请求体、处理业务、返回200状态码即可，基础Python示例代码如下：

import json

def lambda_handler(event, context):
    try:
        # 解析Azure传来的POST请求体
        request_data = json.loads(event.get("body", "{}"))
        # 此处替换为你的业务逻辑：存S3、写数据库、触发其他AWS服务均可
        print("接收Azure数据成功:", request_data)
        
        return {
            "statusCode": 200,
            "headers": {"Content-Type": "application/json"},
            "body": json.dumps({"status": "success"})
        }
    except Exception as e:
        print("请求处理异常:", str(e))
        return {
            "statusCode": 500,
            "body": json.dumps({"status": "error", "msg": str(e)})
        }

配置完成后可以先用本地工具发POST请求测试，确认端点能正常接收请求、返回200状态码后再配置Azure侧。

第二步：修改Azure Runbook代码增加转发逻辑 #

你现有代码只完成了SQL查询，只需要在拿到查询结果后增加HTTP POST请求，把数据发到刚才创建的AWS端点即可，修改后的PowerShell代码如下：

$SQLServerCred = Get-AutomationPSCredential -Name "SqlCred"
$SQL_Server_Name = Get-AutomationVariable -Name "SqlServer"
$SQL_DB_Name = Get-AutomationVariable -Name "Database"
# 提前在Azure Automation变量中存好AWS侧的Webhook端点地址
$AWS_Endpoint = Get-AutomationVariable -Name "AWSWebhookUrl"

$Query = "select Calculated from dbo.Testings"
$Results = invoke-sqlcmd -ServerInstance "$SQL_Server_Name" -Database "$SQL_DB_Name" -Credential $SQLServerCred -Query "$Query" -QueryTimeout 420

# 将查询结果序列化为JSON格式适配HTTP传输
$RequestBody = $Results | ConvertTo-Json -Depth 10
$RequestHeaders = @{
    "Content-Type" = "application/json"
    # 如果配置了API Key鉴权，在此处添加请求头传鉴权值即可
    # "X-API-Key" = "你的自定义鉴权密钥"
}

try {
    $AwsResponse = Invoke-RestMethod -Uri $AWS_Endpoint -Method Post -Body $RequestBody -Headers $RequestHeaders -TimeoutSec 300
    Write-Output "数据转发AWS成功，返回: $($AwsResponse | ConvertTo-Json)"
}
catch {
    Write-Error "转发失败，错误信息: $_"
    throw $_
}

配置注意事项 #

• 日志排查：请求异常时优先查两边的原生日志，AWS侧看CloudWatch日志组，Azure侧看Runbook作业执行日志，可快速定位是请求没发出、网络不通还是接收端解析报错
• Payload限制：Lambda/API Gateway单次请求体最大支持6MB，如果你的SQL查询结果数据量较大，不要直接传全量数据，建议先把结果存到Azure Blob，再把文件访问地址发给AWS侧拉取
• 网络配置：如果Lambda部署在VPC内部，需要确认VPC配置了公网访问权限，否则Azure侧的公网请求无法到达端点

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