更新时间:2024-02-23 GMT+08:00
发送rocketmq事件
前提条件:
- 创建rocketmq实例。
图1 创建rocketmq实例
- 创建和rocketmq实例同一vpc、子网的访问端点。
操作步骤:
- 创建事件通道。
图2 创建事件通道
- 创建rocketmq事件源。
图3 创建rocketmq事件源
- 创建rocketmq事件订阅。
图4 创建rocketmq事件订阅
创建事件订阅成功后rocketmq事件源变为运行中
图5 创建事件订阅
- 发送事件。
图6 发送事件
- 查看事件消息格式。
- 查看事件轨迹的事件详情:
图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" }
- 查看目标函数日志:
图8 查看目标函数日志
- 查看事件轨迹的事件详情:
父主题: 事件规则