云消息队列 MQTT 版：消息集成

背景信息

消息集成基于事件总线EventBridge中事件流功能，通过可视化设计与编排，实现消息跨地域、跨实例、跨应用的流转。详情请参见事件流概述。

消息集成可以将云消息队列 MQTT 版中的消息可靠地分发到各类数据目标，在分发时对消息数据进行过滤和转化。

前提条件

消息集成底层基于事件总线EventBridge和函数计算实现，在使用消息集成之前，请确保已开通以下服务。

• 开通事件总线EventBridge并授权。

• （可选）开通函数计算服务。如果任务中使用了Transform（转换）功能则需要开通。

• 开通目标服务。例如，创建流出目标为云消息队列 Kafka 版的集成任务，请先开通云消息队列 Kafka 版服务。

计费说明

• 事件总线EventBridge的计费说明，请参见计费说明。

• 函数计算的计费说明，请参见计费概述。

• 目标服务的计费说明，请参阅官方文档中的相关内容。

旧版 Kafka 规则迁移指引

[TODO: 本段内容待确认 - 旧版 Kafka 规则的可用状态、迁移路径与迁移后差异，需产品/PD 确认后补充，禁止编造]

已创建旧版 Kafka 规则的用户，可参考以下信息判断是否需要迁移到消息集成。

旧版 Kafka 规则的当前状态

[TODO: 需确认 - 旧版 Kafka 规则当前是否仍可正常使用、是否仍支持新建，以及存在哪些功能或地域限制]

[TODO: 需确认数值 - 停用时间线（如产品侧已确定停用计划，请在此处补充具体日期或阶段；未确定则不写此项）]

迁移至消息集成的操作路径

[TODO: 需补充步骤 - 从旧版 Kafka 规则迁移到消息集成任务的具体操作步骤，包括在控制台的入口位置]

迁移后的计费与功能差异

[TODO: 需确认 - 迁移到消息集成（基于事件总线 EventBridge事件流）后的计费方式变化，以及与旧版 Kafka 规则相比新增或缺失的功能]

权限策略

• 阿里云账号：在控制台创建消息集成任务时，控制台会弹出详细授权策略，按照控制台提示确认授权即可。

• RAM用户：RAM用户至少要求阿里云账号授权以下策略：

  • AliyunMQFullAccess：管理云消息队列 MQTT 版的权限。

  • AliyunFCFullAccess：管理函数计算的权限。

  • AliyunEventBridgeFullAccess：管理事件总线EventBridge的权限。

  • 目标服务的管理权限。

  除上述必要权限外，如需使用扩展能力需额外授权。例如：

  • 如需通过VPC网络访问目标服务，需要被授予AliyunVPCFullAccess权限策略来管理VPC资源。

  • 如需查看函数计算FC（Function Compute）运行日志等信息，需要被授予AliyunLogFullAccess权限策略来管理日志服务。