ApsaraMQ for MQTT：訊息整合

背景資訊

訊息整合基於事件匯流排EventBridge中事件流功能，通過可視化設計與編排，實現訊息跨地區、跨執行個體、跨應用的流轉。詳情請參見事件流概述。

訊息整合可以將雲Message QueueTT 版中的訊息可靠地分發到各類資料目標，在分發時對訊息資料進行過濾和轉化。

前提條件

訊息整合底層基於事件匯流排EventBridge和Function Compute實現，在使用訊息整合之前，請確保已開通以下服務。

• 開通事件匯流排EventBridge並授權。

• （可選）開通Function Compute服務。如果任務中使用了Transform（轉換）功能則需要開通。

• 開通目標服務。例如，建立流出目標為ApsaraMQ for Kafka的整合任務，請先開通ApsaraMQ for Kafka服務。

計費說明

• 事件匯流排EventBridge的計費說明，請參見計費說明。

• Function Compute的計費說明，請參見計費概述。

• 目標服務的計費說明，請參閱官方文檔中的相關內容。

舊版 Kafka 規則遷移指引

[TODO: 本段內容待確認 - 舊版 Kafka 規則的可用狀態、遷移路徑與遷移後差異，需產品/PD 確認後補充，禁止編造]

已建立舊版 Kafka 規則的使用者，可參考以下資訊判斷是否需要遷移到訊息整合。

舊版 Kafka 規則的目前狀態

[TODO: 需確認 - 舊版 Kafka 規則當前是否仍可正常使用、是否仍支援建立，以及存在哪些功能或地區限制]

[TODO: 需確認數值 - 停用時間軸（如產品側已確定停用計劃，請在此處補充具體日期或階段；未確定則不寫此項）]

遷移至訊息整合的操作路徑

[TODO: 需補充步驟 - 從舊版 Kafka 規則遷移到訊息整合任務的具體操作步驟，包括在控制台的入口位置]

遷移後的計費與功能差異

[TODO: 需確認 - 遷移到訊息整合（基於事件匯流排 EventBridge事件流）後的計費方式變化，以及與舊版 Kafka 規則相比新增或缺失的功能]

權限原則

• 阿里雲帳號：在控制台建立訊息整合任務時，控制台會彈出詳細授權策略，按照控制台提示確認授權即可。

• RAM使用者：RAM使用者至少要求阿里雲帳號授權以下策略：

  • AliyunMQFullAccess：管理雲Message QueueTT 版的許可權。

  • AliyunFCFullAccess：管理Function Compute的許可權。

  • AliyunEventBridgeFullAccess：管理事件匯流排EventBridge的許可權。

  • 目標服務的系統管理權限。

  除上述必要許可權外，如需使用擴充能力需額外授權。例如：

  • 如需通過VPC網路訪問目標服務，需要被授予AliyunVPCFullAccess權限原則來管理VPC資源。

  • 如需查看Function ComputeFC（Function Compute）作業記錄等資訊，需要被授予AliyunLogFullAccess權限原則來管理Log Service。