前提条件
-
已经创建函数。
-
创建RabbitMQ触发器,必须开启函数工作流VPC访问。
-
已经创建RabbitMQ实例。
-
确认实例安全组规则是否配置正确。
- 在RabbitMQ实例详情页面的“基本信息 > 网络”,单击安全组名称,跳转到安全组页面。
- 选择“入方向规则”,查看安全组入方向规则。
- 实例未开启SSL开关
- 如果是VPC内访问,实例安全组入方向规则,需要允许端口5672的访问。
- 如果是公网访问,需要允许端口15672的访问。
- 实例已开启SSL开关
- 如果是VPC内访问,实例安全组入方向规则,需要允许端口5671的访问。
- 如果是公网访问,需要运行端口15671的访问。
- 实例未开启SSL开关
创建RabbitMQ触发器
- 登录函数工作流控制台,在左侧的导航栏选择“函数 > 函数列表”。
- 选择待配置的函数,单击进入函数详情页。
- 选择“设置 > 触发器”,单击“创建触发器”,弹出“创建触发器”对话框。
- 设置以下信息。
- 触发器类型:选择“分布式消息服务RabbitMQ版 (RABBITMQ)”。
- 实例:选择已创建RabbitMQ实例。
- 交换机名称:填写用户需要使用的交换机名称。
- 密码:填写创建RabbitMQ实例的密码。
- 虚拟机名称:填写用户自定义的vhost。
- 批处理大小:每次从Topic消费的消息数量。
- 单击“确定”,完成RabbitMQ触发器的创建。
说明开启函数流VPC访问后,需要在RabbitMQ服务安全组配置对应子网的权限。
配置RabbitMQ事件触发函数
- 返回函数工作流控制台,在左侧的导航栏选择“函数 > 函数列表”。
- 选择待配置的函数,单击进入函数详情页。
- 在函数详情页,选择函数版本。
- 在“代码”页签下,单击“测试”,弹出“配置测试事件”对话框。
- 填写如表所示测试信息后,单击“保存”。
表 测试信息
参数 | 说明 |
---|---|
配置测试事件 | 可创建新的测试事件也可编辑已有的测试事件。选择默认值:“创建新的测试事件”。 |
事件模板 | 选择“rabbitmq-event-template模板”,使用系统内置RabbitMQ事件模板。 |
事件名称 | 事件名称必须以大写或小写字母开头,支持字母(大写或小写),数字和下划线“_”(或中划线“-”),并以字母或数字结尾,长度为1-25个字符,例如kafka-123test。 |
测试事件 | 自动加载系统内置RabbitMQ事件模板,本例不做修改。 |
- 单击“测试”,可以得到函数运行结果,函数会返回输入RabbitMQ消息数据。