路由到消息服务MNS

创建事件流

1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
2. 在顶部菜单栏，选择地域，然后单击创建事件流。

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

   • 任务创建

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

     2. 在Sink（目标）配置向导，选择服务类型为消息服务MNS，配置以下参数。

        参数	说明	示例
        队列名称	选择已创建的消息服务MNS队列。	test
        开启 Base64 编码	选择是否开启Base64编码，如不开启，会导致接收到的消息为乱码。	是
        消息体（body）	选择事件内容转换类型。更多信息，请参考事件内容转换。	完整事件

   • 任务属性

     设置事件流的重试策略及死信队列。更多信息，请参见重试和死信。

4. 返回事件流页面，找到创建好的事件流，在其右侧操作栏，单击启用。

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

结果验证

您可以在消息服务MNS控制台确认是否接收到事件。

1. 登录消息服务MNS控制台，在左侧导航栏，单击队列列表。

2. 在顶部菜单栏，选择地域。

3. 在队列列表页面，找到目标队列，在其右侧操作列选择更多 > 收发消息。

4. 在队列收发消息快速体验页面的接收消息区域，单击接收消息。

   接收到的示例消息内容如下所示。

   {
       "data":{
          "props":{
               "firstTopic":"topci12****",
               "secondTopic":"",
               "clientId":"GID_MQTT_CONSOLE@@@lmqhb1share01vpc165759566****"
          },
          "body":"Hello World"
       },
       "id":"AC11C08E76C67E7740853B0F604D****",
       "source":"acs:mqtt",
       "specversion":"1.0",
       "type":"mqtt:Topic:SendMessage",
       "datacontenttype":"application/json; charset\u003dutf-8",
       "time":"2022-07-12T03:14:23.447Z",
       "subject":"acs:mq:cn-qingdao:182572506381****:topic/mqtt-cn-2r42rdr****/topci12****",
       "aliyunaccountid":"182572506381****"
   }