您可以通過事件規則過濾事件，將事件路由到消息隊列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"
    }
}