更新时间:2025-08-07 GMT+08:00

分布式消息服务RocketMQ版

本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。

前提条件

创建RocketMQ事件源

  1. 登录事件网格控制台
  1. 在左侧导航栏选择“事件源”,进入“事件源”页面。
  2. 单击“创建事件源”,弹出“创建事件源”对话框。
  3. 参考表1,填写自定义事件源的配置信息。

    表1 RocketMQ事件源参数说明

    参数名称

    说明

    提供方

    默认为“自定义”。

    事件源类型

    事件源类型选择“分布式消息服务RocketMQ版”。
    说明:

    如之前未创建授权委托,事件源类型首次选择“分布式消息服务RocketMQ版”时,系统会自动弹出创建委托授权界面,需要您创建授权委托,详情请查看授权委托

    事件源名称

    您自定义的事件源名称,用于识别不同的事件源。

    事件源创建成功后,事件源名称不支持修改。

    描述(可选)

    事件源的描述信息。

    通道

    选择一个已创建的自定义事件通道,也可以单击“创建事件通道”新建事件通道。

    事件源创建成功后,事件通道不支持修改。

    RocketMQ实例

    选择消息队列RocketMQ版中的实例名称。

    若选择“无”,表示添加用户自建的消息队列RocketMQ版实例。

    Topic

    RocketMQ实例的Topic。

    消费组

    RocketMQ实例的消费组。

    用户名

    RocketMQ实例开启ACl访问控制的时候需要填写实例的用户名。

    密钥

    RocketMQ实例开启ACl访问控制的时候需要填写实例的密钥。

    虚拟私有云

    当“RocketMQ实例”选择“无”时参数可见,选择虚拟私有云。

    子网

    当“RocketMQ实例”选择“无”时参数可见,选择子网。

    连接地址

    当“RocketMQ实例”选择“无”时参数可见,输入自建RocketMQ版实例的连接地址。

    SSL

    当“RocketMQ实例”选择“无”时参数可见,配置是否开启SSL。

    自建RocketMQ事件源处于“运行中”时,不支持修改SSL。如果涉及SSL变化,建议该事件源删除重建。

    ACL访问控制

    当“RocketMQ实例”选择“无”时参数可见,配置是否开启ACL访问控制。

  4. 单击“确定”,完成自定义事件源的创建。

    创建成功后,在“自定义事件源”页签,查看创建的事件源。

    • 如果需要修改自定义事件源的描述信息,单击待修改事件源后的“编辑”,在弹出的对话框中编辑描述及相关参数信息。
    • 如果需要查看自定义事件源的信息,单击待查看信息的事件源名称,在弹出的对话框中查看自定义事件源信息。

事件格式查看

前提条件:

  1. 已创建RocketMQ实例。
  2. 创建和RocketMQ实例同一VPC、子网的访问端点。
  1. 创建事件通道。
  2. 创建RocketMQ事件源。
  3. 创建事件源为RocketMQ,事件目标为“FunctionGraph(函数计算)”的事件订阅。
  4. 发送事件。

    图1 发送事件

  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名称,即可查看日志详情。