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

前提条件

创建事件流

  1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
  2. 在顶部菜单栏，选择地域，然后单击创建事件流。
  3. 在创建事件流面板，配置以下参数，然后单击创建。
    1. 在基本信息页签，设置事件流名称和描述，单击下一步。
    2. 在事件源页签和规则页签，设置事件源和事件规则，然后单击下一步。
    3. 在目标页签，选择服务类型为消息队列 RabbitMQ 版，设置以下参数，然后单击创建。
      参数 说明 示例
      实例ID 选择已创建的消息队列RabbitMQ版实例。 amqp-cn-zvp2pny6****
      Vhost 选择已创建的Vhost。 test
      目标类型
      • Exchange 模式：生产者将消息发送到Exchange，由Exchange将消息路由到一个或多个Queue中。
      • Queue 模式：每个消息都会被投入到一个或多个Queue里。
      		Queue 模式
      Queue 选择接收消息的队列。 queue
      Body 事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。 部分事件
      $.data.body
      MessageId 事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。 部分事件
      $.data.props.messageId
      Properties 事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。 部分事件
      $.data.props
    4. 返回事件流页面，找到创建好的事件流，在其右侧操作栏，单击启用。
      启用事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

结果验证

  1. 登录消息队列RabbitMQ版控制台，在概览页面的资源分布区域，选择地域。
  2. 在实例列表页面，单击目标实例名称。
  3. 在实例详情页面的基本信息区域，单击消息查询。
  4. 在消息查询页面，选择查询方式为按 Queue 查询，设置时间范围，然后单击查询。
    查询Rabbit消息