# 分布式消息服务RocketMQ版
本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。
#### 前提条件
- （可选）创建自定义事件源前，需要先[创建自定义事件通道](https://support.huaweicloud.com/usermanual-eg/eg-ug-054.html)。
- 已购买分布式消息服务RocketMQ版实例，实例中已创建Topic，且实例状态处于"运行中"。具体步骤，请参考[购买实例](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-002.html)。
- 已[创建私网访问端点](https://support.huaweicloud.com/usermanual-eg/eg-ug-034.html#eg-ug-034__section93178455526)，其VPC及子网与RocketMQ实例相同。
- 已正确配置default安全组和RocketMQ实例所属的安全组规则，具体规则请参考[创建事件源如何配置安全组](https://support.huaweicloud.com/eg_faq/eg-faq-009.html)。
 
#### 创建RocketMQ事件源
1. 登录[事件网格控制台](https://console.huaweicloud.com/egs)。

2. 在左侧导航栏选择"事件源"，进入"事件源"页面。
3. 单击"创建事件源"，弹出"创建事件源"对话框。
4. 参考[表1]，填写自定义事件源的配置信息。
   
    表1RocketMQ事件源参数说明 
   | 参数名称       | 说明   ||
   |:---|:--|---|
   | 提供方        | 默认为"自定义"。  ||
   | 事件源类型      | 事件源类型选择"分布式消息服务RocketMQ版"。 说明： 如之前未创建授权委托，事件源类型首次选择"分布式消息服务RocketMQ版"时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看[授权委托](https://support.huaweicloud.com/usermanual-eg/eg-ug-035.html)。 ||
   | 事件源名称      | 您自定义的事件源名称，用于识别不同的事件源。 事件源创建成功后，事件源名称不支持修改。 ||
   | 描述（可选）     | 事件源的描述信息。 ||
   | 通道         | 选择一个已创建的自定义事件通道，也可以单击"创建事件通道"新建事件通道。 事件源创建成功后，事件通道不支持修改。 ||
   | RocketMQ实例 | 选择消息队列RocketMQ版中的实例名称。 若选择"无"，表示添加用户自建的消息队列RocketMQ版实例。 ||
   | Topic      | RocketMQ实例的Topic。 ||
   | 消费组        | RocketMQ实例的消费组。 ||
   | 用户名        | RocketMQ实例开启ACL访问控制的时候需要填写实例的用户名。 ||
   | 密钥         | RocketMQ实例开启ACL访问控制的时候需要填写实例的密钥。 ||
   | 虚拟私有云      | 当"RocketMQ实例"选择"无"时参数可见，选择虚拟私有云。 ||
   | 子网         | 当"RocketMQ实例"选择"无"时参数可见，选择子网。 ||
   | 连接地址       | 当"RocketMQ实例"选择"无"时参数可见，输入自建RocketMQ版实例的连接地址。 ||
   | SSL        | 当"RocketMQ实例"选择"无"时参数可见，配置是否开启SSL。 **自建RocketMQ事件源处于"运行中"时，不支持修改SSL。如果涉及SSL变化，建议该事件源删除重建。** ||
   | ACL访问控制    | 当"RocketMQ实例"选择"无"时参数可见，配置是否开启ACL访问控制。 ||
      
   
   
5. 单击"确定"，完成自定义事件源的创建。 
   创建成功后，在"自定义事件源"页签，查看创建的事件源。
   ![](https://support.huaweicloud.com/usermanual-eg/public_sys-resources/note_3.0-zh-cn.png)
   - 如果需要修改自定义事件源的描述信息，单击待修改事件源后的"编辑"，在弹出的对话框中编辑描述及相关参数信息。
   
   - 如果需要查看自定义事件源的信息，单击待查看信息的事件源名称，在弹出的对话框中查看自定义事件源信息。
    
   
   
 
#### 事件格式查看
前提条件：
1. 已创建RocketMQ实例。
2. 创建和RocketMQ实例同一VPC、子网的访问端点。

1. 创建事件通道。
2. 创建RocketMQ事件源。
3. 创建事件源为RocketMQ，事件目标为"FunctionGraph（函数计算）"的事件订阅。
4. 发送事件。 
   图1发送事件   
   ![](https://support.huaweicloud.com/usermanual-eg/zh-cn_image_0000001794848338.png "点击放大")
   
   
5. 查看事件消息格式。 
   1. 查看事件轨迹的事件详情。 消息体事件格式如下：
      ```
      {
        "datacontenttype": "application/json",
        "data": {
          "context": "{\"hello\":\"world\"}",
          "topic": "topic-test"
        },
        "subject": "ROCKETMQ:cn-north-4:f003dc69-2fc3-4c44-9062-0b9a2c6cb8cc/0ef1e7a03280f3ed2f69c00c652a5744:ROCKETMQ:source-rocketmq",
        "specversion": "1.0",
        "id": "e6cc599b-0664-4078-87dd-5630087d5f7e",
        "source": "source-rocketmq",
        "time": "2024-02-05T14:20:31Z",
        "type": "ROCKETMQ:CloudTrace:RocketmqCall"
      }
      ```
      
   
   2. 查看目标函数日志。
      1. 进入函数工作流控制台，左侧导航栏选择"函数 \> 函数列表"，单击目标函数名称进入详情页面。
      
      2. 在详情页面内，选择"监控 \> 日志 \> 请求列表"，单击列表中的请求ID名称，即可查看日志详情。