本文介绍如何在事件总线EventBridge管理控制台添加分布式消息服务RocketMQ作为事件流中的服务类型。

前提条件

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

• 开通分布式消息服务RocketMQ，并创建实例。

创建事件流

1. 登录事件总线EventBridge管理控制台，在左侧导航栏，单击事件流。

2. 在创建事件流面板，设置任务名称和描述，配置以下参数，然后单击创建。

   1.   在Source（源）、Filtering（过滤）、Transform（转换）配置向导，设置数据提供方、事件过滤、转换规则，单击下一步。事件转换的配置说明，请参见使用函数计算实现消息数据清洗。

   2.   在Sink（目标）配置向导，选择服务类型分布式消息服务RocketMQ，配置以下参数，如图1所示。

      

      图1 创建事件流时选择目标服务类型为分布式消息服务RocketMQ

3. 创建事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

参数说明

结果验证

1. 使用事件源触发一个事件事件。

2. 您可以在分布式消息服务RocketMQ管理控制台确认是否接收到事件。

   1. 登录分布式消息服务RocketMQ管理控制台，然后在左侧导航栏选择实例列表。

   2. 在实例列表页面单击目标实例名称。

   3. 在消息查询页面，按时间查询即可查看消息内容，如图2所示。

      

      图2 在分布式消息服务RocketMQ管理控制台中查看消息详情