如何通过Azure门户将Blob存储中的消息迁移回Event Hub

Azure 门户原生不支持直接将 Blob 中存储的失败消息一键迁移回 Event Hub，没有开箱即用的内置迁移/重投递功能。

你不需要额外部署本地工具，完全可以在门户内完成生产环境的故障消息重投递，有两种常用路径：

• 手动操作路径（适合少量失败消息的应急重投）
  1. 进入存储账户对应的存储浏览器，定位到存放失败消息的 Blob 容器，下载待重投递的消息文件，提前清理转存时附加的错误码、异常时间戳等额外字段，保证消息体格式和最初写入Event Hub的格式完全一致，避免触发器消费时出现解析失败。
  2. 进入目标Event Hub的实体页面，打开内置的数据浏览器，选择「发送事件」功能，分批次上传整理好的消息即可完成重投。注意单批次消息总大小不要超过1MB，发送速率不要超过Event Hub配置的吞吐量单位阈值，避免触发发送端限流。
• 自动化配置路径（适合频繁需要重投递的生产场景）
  你可以直接在Azure门户创建一个 Consumption 层级的逻辑应用，配置手动触发触发器，逻辑流程设置为：读取指定Blob路径下的所有失败消息 -> 自动做格式校验 -> 按可控的并发速率批量发送到目标Event Hub -> 发送成功后自动将对应Blob移动到归档容器，避免重复投递。整个配置过程全程可视化，不需要编写部署额外的服务代码，还可以开启操作审计，跟踪每一条消息的重投状态。

重要提醒：执行重投递操作前必须先确认之前的故障根因已经修复（比如Cosmos的限流配额已经调整、触发未处理异常的代码问题已经上线修复），否则消息重投后会再次处理失败，重新写入Blob，形成无效的消息循环。

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