tongchenkeji 发表于:2023-5-6 10:00:500次点击 已关注取消关注 关注 私信 使用rocketMQ 通过eventbridge进行触发,这个推送格式怎么在s.yaml中声明?[阿里云函数计算] 暂停朗读为您朗读 使用rocketMQ 通过eventbridge进行触发,这个推送格式怎么在s.yaml中声明? 我想直接收mq里的原始数据,我现在收到的被eventbridge转了一道,多了很多内容。 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 函数计算# RocketMQ973# 云消息队列 MQ1430# 消息中间件1371
wljslmzAM 2023-11-27 21:28:56 1 使用 RocketMQ 通过 EventBridge 进行触发时,您可以在 Serverless Devs 的 YAML 配置文件中使用 eventBridge 触发器,并在其中设置 eventSource 属性为 acs:mq,以指定触发器的事件源为 RocketMQ。 以下是一个使用 eventBridge 触发器触发 RocketMQ 的示例: triggers: - eventBridge: eventBus: eventSource: acs:mq detailType: RocketMQ Message detail: topic: tags: - tag1 - tag2 在上面的示例中,eventBus 属性用于指定要使用的 EventBridge 事件总线名称,eventSource 属性用于指定事件源为 RocketMQ,detailType 属性用于指定事件类型为 "RocketMQ Message",detail 属性用于指定触发事件的详细信息,例如 RocketMQ 的主题名称和标签等信息。 RocketMQ 的消息体格式是自定义的,您需要根据您的业务需求来设置正确的消息体格式。如果 RocketMQ 的消息体格式不符合 EventBridge 触发器的要求,您可能需要编写自定义代码来将 RocketMQ 消息转换为 EventBridge 触发器所期望的格式。
使用 RocketMQ 通过 EventBridge 进行触发时,您可以在 Serverless Devs 的 YAML 配置文件中使用
eventBridge
触发器,并在其中设置eventSource
属性为acs:mq
,以指定触发器的事件源为 RocketMQ。以下是一个使用
eventBridge
触发器触发 RocketMQ 的示例:在上面的示例中,
eventBus
属性用于指定要使用的 EventBridge 事件总线名称,eventSource
属性用于指定事件源为 RocketMQ,detailType
属性用于指定事件类型为 "RocketMQ Message",detail
属性用于指定触发事件的详细信息,例如 RocketMQ 的主题名称和标签等信息。RocketMQ 的消息体格式是自定义的,您需要根据您的业务需求来设置正确的消息体格式。如果 RocketMQ 的消息体格式不符合 EventBridge 触发器的要求,您可能需要编写自定义代码来将 RocketMQ 消息转换为 EventBridge 触发器所期望的格式。
只有改成事件流然后把这个改成rawData才行
此答案来自钉钉群“阿里函数计算官网客户”