更新时间:2024-06-27 GMT+08:00
分享

发送RocketMQ事件

前提条件:

  1. 创建rocketmq实例。
    图1 创建rocketmq实例
  2. 创建和rocketmq实例同一vpc、子网的访问端点。

操作步骤:

  1. 创建事件通道。

    图2 创建事件通道

  2. 创建rocketmq事件源。

    图3 创建rocketmq事件源

  3. 创建rocketmq事件订阅。

    图4 创建rocketmq事件订阅

    创建事件订阅成功后rocketmq事件源变为运行中

    图5 创建事件订阅

  4. 发送事件。

    图6 发送事件

  5. 查看事件消息格式。

    1. 查看事件轨迹的事件详情:
      图7 查看事件详情

      消息体事件格式如下:

      {
      "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. 查看目标函数日志:
      图8 查看目标函数日志

分享:

    相关文档

    相关产品