集成概述

背景信息

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

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

前提条件

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

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

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

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

计费说明

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

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

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

权限策略

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

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

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

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

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

  • 目标服务的管理权限。

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

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

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