路由到分布式消息服務RocketMQ
 
                  更新時間 2025-06-18 17:55:23
                    
 
                    最近更新時間: 2025-06-18 17:55:23
                  
   分享文章 
本文介紹如何在事件總線EventBridge管理控制臺添加分布式消息服務RocketMQ作為事件流中的服務類型。
前提條件
- 開通分布式消息服務RocketMQ,并創建實例。 
創建事件流
- 登錄事件總線EventBridge管理控制臺,在左側導航欄,單擊事件流。 
- 在創建事件流面板,設置任務名稱和描述,配置以下參數,然后單擊創建。 - 在Source(源)、Filtering(過濾)、Transform(轉換)配置向導,設置數據提供方、事件過濾、轉換規則,單擊下一步。事件轉換的配置說明,請參見使用函數計算實現消息數據清洗。 
- 在Sink(目標)配置向導,選擇服務類型分布式消息服務RocketMQ,配置以下參數,如圖1所示。 - 圖1 創建事件流時選擇目標服務類型為分布式消息服務RocketMQ 
 
- 創建事件流后,會有30秒~60秒的延遲時間,您可以在事件流頁面的狀態欄查看啟動進度。 
參數說明
| 參數 | 說明 | 示例 | 
|---|---|---|
| 實例 | 選擇分布式消息服務RocketMQ實例。 | instance-xxx | 
| Topic | 選擇RocketMQ實例的Topic。 | topic1 | 
| 消息體 | 選擇消息體(Body)的內容,更多內容請參考事件內容轉換。 | 完整事件 | 
| 自定義屬性 | 選擇自定義屬性(Properties)的內容,請參考事件內容轉換。 | 空 | 
| 索引 | 選擇索引(Keys)的內容,更多的內容,請參考事件內容轉換。 | 空 | 
| 標簽 | 選擇標簽(Tags)的內容,更多的內容,請參考事件內容轉換。 | 空 | 
結果驗證
- 使用事件源觸發一個事件事件。 
- 您可以在分布式消息服務RocketMQ管理控制臺確認是否接收到事件。 - 登錄分布式消息服務RocketMQ管理控制臺,然后在左側導航欄選擇實例列表。 
- 在實例列表頁面單擊目標實例名稱。 
- 在消息查詢頁面,按時間查詢即可查看消息內容,如圖2所示。 - 圖2 在分布式消息服務RocketMQ管理控制臺中查看消息詳情 
 
