如何通过REST API从Azure Data Factory向Event Hub发布消息及相关问题咨询

一、Web活动调用Event Hub REST API授权问题解决 #

Event Hub REST API的授权主要靠SAS令牌或Azure AD OAuth，对应Postman的使用方式，在ADF里做如下配置：

1. SAS令牌快速实现 #

• 生成SAS令牌：登录Azure门户，进入Event Hub命名空间的「共享访问策略」，选择带有Send权限的策略，生成包含sr、sig、se参数的完整令牌
• ADF Web活动配置：
  • 请求方法选POST
  • 请求URL填：https://<你的命名空间>.servicebus.windows.net/<Event Hub名称>/messages
  • 请求头添加：
    • Content-Type: application/json
    • Authorization: SharedAccessSignature sr=...（把生成的SAS令牌完整填入）
  • 请求Body里放入和Postman一致的消息内容，比如{"id":1,"content":"test"}

常见授权错误排查点 #

• 确认SAS令牌权限：必须包含Send，别误选成Listen或Manage权限
• 检查令牌过期时间：若提示令牌过期，重新生成新的SAS令牌
• 核对请求头格式：Authorization必须以SharedAccessSignature开头，不能遗漏前缀
• 验证URL拼写：确保命名空间、Event Hub名称无拼写错误

2. Azure AD OAuth安全方案 #

如果不想使用SAS令牌，可采用ADF托管身份授权：

• 给ADF的托管身份分配Event Hub的「Azure Event Hubs Data Sender」角色
• 在Web活动的「身份验证」选项中，选择Managed Identity，资源填写https://eventhubs.azure.net/
• 无需手动添加Authorization请求头，ADF会自动生成并注入Bearer token

二、Oracle查询结果推送到Event Hub REST端点 #

复制活动无法直接将Oracle数据发送到Event Hub REST端点，需拆分两步实现：

1. 将Oracle数据导出到临时存储 #

• 使用复制活动，源配置本地Oracle数据库（需搭配自托管集成运行时），写入目标查询语句
• 接收器选择Azure Blob Storage，将查询结果保存为每行一条JSON的文件（配置数据集格式为JSON，行分隔符选换行）

2. 循环调用REST API发送数据 #

• 添加ForEach活动，遍历Blob存储中的JSON文件内容（可通过@activity('复制活动名称').output.files获取文件列表）
• 在ForEach内部添加Web活动，配置与前文一致的Event Hub REST端点和授权方式，请求Body设置为@item()（即当前遍历到的单条数据）

高效替代方案：映射数据流 #

若数据量较大，推荐使用映射数据流直接对接：

• 源选择Oracle，设置查询条件
• 接收器选择Event Hub内置连接器（无需调用REST API），配置批量发送规则
• 该方式自带批量处理能力，比循环调用REST API效率更高

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