您可以通过事件规则过滤事件,将事件路由到消息队列RocketMQ版。本文以自定义事件为例介绍将事件路由到消息队列RocketMQ版的前提条件、操作步骤和结果验证。

步骤一:添加自定义事件源

  1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线
  2. 在顶部菜单栏,选择地域,在事件总线页面,单击目标自定义事件总线名称。
  3. 在左侧导航栏,单击事件源,然后单击添加事件源
  4. 添加自定义事件源面板,输入名称描述事件提供方选择自定义应用,然后单击确定

步骤二:创建事件规则

重要 目标服务和事件规则必须处于同一地域。
  1. 登录事件总线EventBridge控制台
  2. 在左侧导航栏,单击事件总线
  3. 在顶部菜单栏,选择地域。
  4. 事件总线页面,单击目标总线名称。
  5. 在左侧导航栏,单击事件规则
  6. 事件规则页面,单击创建规则
  7. 创建规则页面,完成以下操作。
    1. 配置基本信息配置向导,在名称文本框输入规则名称,在描述文本框输入规则的描述,然后单击下一步
    2. 配置事件模式配置向导,事件源类型选择自定义事件源事件源选择步骤一添加的自定义事件源,在模式内容代码框输入事件模式,然后单击下一步

      如需了解更多信息,请参见事件模式

    3. 配置事件目标配置向导,配置事件目标,然后单击创建
      说明 1个事件规则最多可以添加5个目标。

      事件目标消息队列RocketMQ版涉及配置的参数如下:

      参数名称 参数说明
      服务类型 单击消息队列 RocketMQ 版
      实例 ID 选择已创建的消息队列 RocketMQ 版的实例ID。
      Topic 选择已创建的Topic。
      消息体(Body) 事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。例如:

      部分事件

      $.data.body
      自定义属性(Properties) 事件总线EventBridge通过JSONPath提取事件中的数据,将指定的属性路由到事件目标。例如:

      模板

      变量
      {
        "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

      针对事件内容,事件总线EventBridge提供不同的转换类型,详细信息,请参见事件内容转换。每种类型的简单示例如下:

      • 部分事件示例:
        $.data.body
      • 常量示例:
        请注意告警!
      • 变量模板的示例:

        变量示例:

        {
          "type":"$.type"
        }

        模板示例:

        The event type is ${type}.

步骤三:发布事件

  1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线
  2. 在顶部菜单栏,选择地域。
  3. 事件总线页面,找到目标总线,在其右侧操作列单击发布事件
    说明 仅自定义事件总线支持通过控制台发布事件。
  4. 发布事件至自定义事件总线面板,自定义事件源下拉列表选择已创建的自定义事件源,在事件体代码框输入事件内容,然后单击确定
    事件包含的参数规范,请参见事件概述

结果验证

您可以在消息队列RocketMQ版控制台确认是否接收到事件。

  1. 登录消息队列RocketMQ版控制台
  2. 在左侧导航栏,单击实例列表
  3. 在顶部菜单栏,选择地域,如华东1(杭州)
  4. 实例列表页面,找到目标实例,在其右侧操作列选择更多 > 消息查询
  5. 消息查询页面,选择查询方式按Topic查询,选择要查询消息的Topic,设置要查询的时间范围,然后单击查询

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

{
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"acs:mq",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:123456789098****:MQ_INST_123456789098****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunpublishtime":"2021-04-08T06:01:20.725Z",
    "aliyuneventbusname":"BusName",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "UNIQ_KEY":"AC14C305069E1B28CDFA3181CDA2****",
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_123456789098****_BXhFHryi"
        },
        "userProperties":{
        },
        "body":"TEST"
    }
}