本文介绍如何在事件总线EventBridge控制台添加消息队列RocketMQ版作为事件流中的服务类型。

前提条件

创建事件流

  1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
  2. 在顶部菜单栏，选择地域，然后单击创建事件流。
  3. 在创建事件流面板，配置以下参数，然后单击创建。
    1. 在基本信息页签，设置事件流名称和描述，单击下一步。
    2. 在事件源页签和规则页签，设置事件源和事件规则，然后单击下一步。
    3. 在目标页签，选择服务类型为消息队列 RocketMQ 版，设置以下参数，然后单击创建。
      参数 说明 示例
      实例ID 选择已创建的消息队列RocketMQ版实例。 test
      Topic 选择已创建的Topic。 test
      Body 事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。 部分事件
      $.data.body
      Properties 选择模板。您可以自定义一个模板，定义模板里需要的变量，事件总线EventBridge可以提取事件中的字段，按照模板定义的形式进行转换。
      说明 如果需要全量传递源端的RocketMQ消息的属性，推荐使用示例中的配置。
      		变量：
      {
  "userProperties":"$.data.userProperties",
  "msgId":"$.data.systemProperties.UNIQ_KEY"
}
      模板：
      {
  "EB_SYS_EMBED_OBJECT":"${userProperties}",
  "UNIQ_KEY":"${msgId}"
}
      Keys 事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。 部分事件
      $.data.systemProperties.KEYS
      Tags 事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。 部分事件
      $.data.systemProperties.TAGS
    4. 返回事件流页面，找到创建好的事件流，在其右侧操作栏，单击启用。
      启用事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

结果验证

  1. 登录消息队列RocketMQ版控制台，在顶部菜单栏，选择地域。
  2. 在左侧导航栏，单击实例列表。
  3. 在实例列表页面，找到目标实例，在其操作列，单击详情。
  4. 在左侧导航栏，单击Topic 管理，然后单击目标Topic名称。
  5. 在Topic详情页面，单击消息查询页签，配置查询方式和时间范围，单击查询。
    查询消息