消息队列 RabbitMQ 版作为事件源通过事件总线EventBridge与函数计算集成后，通过消息队列 RabbitMQ 版触发器（以下简称RabbitMQ触发器）能够触发关联函数执行，通过函数可以对发布到消息队列 RabbitMQ 版中的消息进行自定义处理。本文介绍如何在函数计算控制台创建RabbitMQ触发器、配置函数入口参数和编写代码并测试。
功能简介
您在函数计算的控制台提交触发器创建请求之后，函数计算会根据触发器的配置信息，自动在事件总线EventBridge侧创建事件流资源。
创建完成后，您可以在函数计算控制台查看触发器信息，同时也可以在事件总线EventBridge控制台查看自动创建的资源信息。当源消息队列 RabbitMQ 版实例中有消息入队时，将会触发函数计算执行。执行时会根据您的攒批配置，将一个或多个消息事件以批的形式推送到函数中进行处理，适合端到端的流式数据处理场景。
注意事项
作为触发源的消息队列 RabbitMQ 版实例必须和函数计算的函数在相同的地域。
创建的事件流数量超过上限后，将无法再创建RabbitMQ触发器。
在单个阿里云账号单个地域维度下，关于创建触发器涉及的资源数量的限制，请参见使用限制。
前提条件
事件总线EventBridge
函数计算
消息队列 RabbitMQ 版
步骤一：创建触发器
当您已经创建好RabbitMQ的队列，您需要登录函数计算控制台，进入目标函数，选择配置页签，创建触发器，创建完成点击确定如下图所示。
上图中的配置项如下所示。
调用方式：
同步调用：适用于顺序调用场景。单个（批）事件触发函数调用，等待函数执行完成返回结果后，再由下一个（批）事件继续触发函数调用。同步调用请求正文有效负载最大为32 MB。更多信息，请参见同步调用。
异步调用：可以快速消费事件。单个（批）事件触发函数调用，函数计算会立刻返回响应，再由下一个（批）事件继续触发函数调用。该过程中函数会异步执行。异步调用请求正文有效负载最大为128 KB。更多信息，请参见异步调用。
关于推送配置、重试和死信等高级配置项说明，请参见触发器高级功能。
创建完成后，在触发器名称列表中显示已创建的触发器。如需对创建的触发器进行修改或删除，具体操作，请参见触发器管理。
步骤二：（可选）配置函数入口参数
消息队列 RabbitMQ 版事件源会以event的形式作为输入参数传递给函数，您可以使用代码解析event参数，并对event进行处理。您可以手动将event传给函数模拟触发事件，测试函数代码是否正确。
在函数详情页面的代码页签，单击测试函数右侧的
图标，从下拉列表中，选择配置测试参数。在配置测试参数面板，选择创建新测试事件或编辑已有测试事件，填写事件名称和事件内容，然后单击确定。
event格式如下所示。[ { "id":"bj694332-4cj1-389e-9d8c-b137h30b****", "source":"RabbitMQ-Function-rabbitmq-trigger", "specversion":"1.0", "type":"amqp:Queue:SendMessage", "datacontenttype":"application/json;charset=utf-8", "subject":"acs:amqp:cn-hangzhou:164901546557****:/instances/amqp-cn-tl32e756****/vhosts/eb-connect/queues/housekeeping", "time":"2021-08-12T06:56:40.709Z", "aliyunaccountid":"164901546557****", "aliyunpublishtime":"2021-10-15T08:58:55.140Z", "aliyunoriginalaccountid":"164901546557****", "aliyuneventbusname":"RabbitMQ-Function-rabbitmq-trigger", "aliyunregionid":"cn-chengdu", "aliyunpublishaddr":"42.120.XX.XX", "data":{ "envelope":{ "deliveryTag":98, "exchange":"", "redeliver":false, "routingKey":"housekeeping" }, "body":{ "Hello":"RabbitMQ" }, "props":{ "contentEncoding":"UTF-8", "messageId":"f7622d51-e198-41de-a072-77c1ead7****" } } }, { "id":"bj694332-4cj1-389e-9d8c-b137h30b****", "source":"RabbitMQ-Function-rabbitmq-trigger", "specversion":"1.0", "type":"amqp:Queue:SendMessage", "datacontenttype":"application/json;charset=utf-8", "subject":"acs:amqp:cn-hangzhou:164901546557****:/instances/amqp-cn-tl32e756****/vhosts/eb-connect/queues/housekeeping", "time":"2021-08-12T06:56:40.709Z", "aliyunaccountid":"164901546557****", "aliyunpublishtime":"2021-10-15T08:58:55.140Z", "aliyunoriginalaccountid":"164901546557****", "aliyuneventbusname":"RabbitMQ-Function-rabbitmq-trigger", "aliyunregionid":"cn-chengdu", "aliyunpublishaddr":"42.120.XX.XX", "data":{ "envelope":{ "deliveryTag":98, "exchange":"", "redeliver":false, "routingKey":"housekeeping" }, "body":{ "Hello":"RabbitMQ" }, "props":{ "contentEncoding":"UTF-8", "messageId":"f7622d51-e198-41de-a072-77c1ead7****" } } } ]data字段包含的参数解释如下表所示。关于CloudEvents规范中定义的参数解释，请参见事件概述。
参数
类型
示例值
描述
body
Map
消息内容。
Hello
String
EventBridge
用户数据。
props
Map
消息属性。
contentEncoding
String
utf-8
消息内容编码。
messageId
String
f7622d51-e198-41de-a072-77c1ead7****
消息ID。每条消息的ID取值唯一。
envelope
Map
消息的envelope信息。
deliveryTag
Int
98
消息的Tag。
exchange
String
无
消息的Exchange。
redeliver
Boolean
false
是否支持重发消息。取值说明如下：
true：支持
false：不支持
routingKey
String
housekeeping
消息的路由规则。
步骤三：编写函数代码并测试
完成触发器创建后，您可以开始编写并测试函数代码，以验证代码的正确性。在实际操作过程中，当消息队列 RabbitMQ 版事件通过事件总线EventBridge投递到函数计算时，触发器会自动触发函数的执行。
在函数详情页面的代码页签，在代码编辑器中编写代码，然后单击部署代码。
本文以Node.js函数代码为例。
'use strict'; /* To enable the initializer feature please implement the initializer function as below： exports.initializer = (context, callback) => { console.log('initializing'); callback(null, ''); }; */ exports.handler = (event, context, callback) => { console.log("event: %s", event); // 解析event参数，对event进行处理。 callback(null, 'return result'); }测试函数。
方式一：如果您是配置函数入口参数
event模拟事件源，单击测试函数。方式二：登录云消息队列 RabbitMQ 版控制台，选择您创建的目标队列，点击发送消息，如下图。
执行完成后，在实时日志查看结果。
更多信息
如需对创建的触发器进行修改或删除，具体操作，请参见触发器管理。