更新时间:2024-02-23 GMT+08:00
分布式消息服务RocketMQ版
本章节介绍在事件流里添加分布式消息服务RocketMQ版事件源的方法。
前提条件
- 已在分布式消息服务RocketMQ版中购买RocketMQ实例。
- 当源端为分布式消息服务RocketMQ版时,目标端只支持选择FunctionGraph(函数计算)。
创建分布式消息服务RocketMQ版事件源
- 登录事件网格控制台。
- 在左侧导航栏选择“事件流”,进入“事件流”页面。
- 单击“创建事件流”,进入“创建事件流”页面。
图1 创建事件流
- 单击“事件源”,弹出“配置事件源”对话框。
图2 配置事件源
- 参考表1,填写事件源的配置信息。
- 单击“下一步”,进入规则配置页面,规则配置可参考过滤规则参数说明。
图3 规则配置
- 单击“下一步”完成规则配置,您可以参考路由到函数工作流,继续配置事件流的事件目标。
事件源配置为分布式消息服务RocketMQ版时,配置事件目标为FunctionGraph(函数计算)时,执行方式可选择为“同步”或“异步”。
- 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。
- MQ采集函数首次启动分钟级后生效。
- 广播模式下不支持失败重试,即消费失败后,失败消息不再重试,消费者继续消费新的消息。
- 发送到目标端失败时,将利用RocketMQ本身的重试能力进行重试,目标端需支持处理重复事件,达到重试上限时,源端消息进入RocketMQ对应topic的死信队列,EG事件不再投递。
父主题: 事件源