最近更新时间:2023.12.28 14:38:04
首次发布时间:2022.08.26 16:54:48
函数服务支持对接火山引擎的 消息队列 RocketMQ 版。 通过创建 RocketMQ 触发器,函数服务将作为消费者消费 RocketMQ 中的消息,并将消息传递给用户函数,触发函数代码逻辑。您无需关心函数服务消费消息的细节,只需编写处理消息的函数。本文为您介绍如何创建 RocketMQ 触发器。
函数已开启 VPC 访问功能,详细操作可参见 更新函数配置。
函数至少完成一次全量发布,详细操作可参见 发布函数。
已创建 RocketMQ 实例、 Topic、Consumer Group 及访问密钥,访问密钥需包含订阅权限。详细操作可参见 RocketMQ 快速入门。
登录 函数服务控制台。
在顶部导航栏,选择目标地域。
在 函数列表 页面,选择需要创建触发器的函数,单击函数名称。
在函数详情页面的 触发器 页签下,单击 创建触发器。
在 创建触发器 面板,按要求设置参数。
配置项 | 说明 |
---|---|
触发器类型 | 本场景选择 RocketMQ 触发器。 |
触发器名称 | 自定义触发器名称。同一函数下,触发器名称不可重复。触发器名称创建成功后不支持修改。 |
实例 | 实例,即 RocketMQ 实例,函数服务将扮演指定的 Consumer Group 角色,去消费指定 RocketMQ 实例下指定 Topic 中的消息。请选择前提条件中准备好的 RocketMQ 实例、Topic、Consumer Group。
说明 仅支持选择与函数处于同一 VPC 下的 RocketMQ 实例。 |
重试次数 | 函数发生运行错误(包括用户代码错误和 Runtime 错误)时的最大重试次数。 |
消息顺序 | 选择是否严格按照消息的发布顺序进行消费,请根据业务需要进行选择。
|
立即启用 | 是否在创建触发器的同时启用触发器。只有处于启用状态的触发器才能够正常工作。 |
身份认证 | 输入前提条件中准备好的访问 RocketMQ 实例的访问密钥 AK(AccessKey ID) 和 SK(AccessKey Secret)。访问密钥仅用于身份验证,函数服务不会存储您的访问密钥。 说明
|
备注 | 根据需要输入备注信息。 |
单击 确定,完成 RocketMQ 触发器创建。