事件网格 EG-移动云RocketMQ版:创建移动云 RocketMQ版事件源
创建移动云 RocketMQ版事件源
- 登录事件网格控制台。
- 在左侧导航栏选择“事件流”,进入“事件流”页面。
- 单击“创建事件流”,进入“创建事件流”页面。
图1 创建事件流
- 单击“事件源”,弹出“配置事件源”对话框。
图2 配置事件源
- 参考表1,填写事件源的配置信息。
表1 移动云 RocketMQ版参数说明 参数名称
说明
事件提供方
选择移动云 RocketMQ版。
实例ID
请输入实例ID。
Group ID
请输入Group ID。
Topic
请输入Topic。
Tag
请输入Tag。
说明:表示订阅指定Topic下的Tags。
- * 表示订阅所有消息。
- TagA || TagB || TagC 表示订阅TagA或TagB或TagC的消息。
开启保存消息轨迹
请选择是否开启保存消息轨迹。
启用鉴权认证
请选择是否启用鉴权认证。
Access Key(启用鉴权认证)
请输入Access Key。
Secret Key(启用鉴权认证)
请输入Secret Key。
订阅方式
请选择集群或广播。
接入点类型
请选择公网或私网。
地址
请输入地址。
客户端SDK
请输入客户端SDK上传到OBS的地址。
说明:客户端SDK上传到OBS的地址获取方式可参考常见问题。
消费超时时间(毫秒)
请输入1000到900000之间的整数。
消息类型
请选择普通消息。
消费线程数
请输入20到64之间的整数。
批量消费最大消息数
请输入1到32之间的整数。
批量消费最大等待时长(秒)
请输入0到450之间的整数。
- 单击“下一步”,进入规则配置页面,规则配置可参考过滤规则参数说明。
图3 规则配置
- 单击“下一步”完成规则配置,您可以参考路由到 函数工作流 ,继续配置事件流的事件目标。
事件源配置为移动云RocketMQ版时,配置事件目标为FunctionGraph(函数计算)时,执行方式可选择为“同步”或“异步”。
- 当事件源和事件目标都配置完成后,单击“保存”,完成事件流的创建。
- MQ采集函数首次启动分钟级后生效。
- 广播模式下不支持失败重试,即消费失败后,失败消息不再重试,消费者继续消费新的消息。
- 发送到目标端失败时,将利用RocketMQ本身的重试能力进行重试,目标端需支持处理重复事件,达到重试上限时,源端消息进入RocketMQ对应topic的死信队列,EG事件不再投递。
- RocketMQ是什么_RocketMQ介绍_分布式消息服务RocketMQ版
- 华为云事件网格_事件源_事件目标
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- RocketMQ的架构_RocketMQ的消息模式_分布式消息RocketMQ-华为云
- 事件网格是什么_事件发送流程_事件网格消息中间件
- 分布式消息队列是什么_分布式消息队列好处_消息队列-华为云
- 分布式消息中间件的作用_分布式消息中间件_分布式消息-华为云
- 分布式消息服务有哪些_分布式消息服务哪个好_分布式消息-华为云
- 分布式消息服务优势_分布式消息服务_消息队列-华为云
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云