MNS队列触发器

消息服务MNS的队列（Queue）作为事件源通过事件总线EventBridge与函数计算集成后，通过消息服务MNS队列触发器（以下简称MNS队列触发器）能够触发关联函数执行，通过函数可以对发布到消息服务MNS队列中的消息进行自定义处理。本文介绍如何在函数计算控制台创建MNS队列触发器、编写函数和测试函数。

功能简介

您在函数计算的控制台提交触发器创建请求之后，函数计算根据触发器的配置信息，将自动创建如下与事件总线EventBridge相关的资源：

事件总线MNS-函数名称-触发器名称
事件源MNS-函数名称-触发器名称
事件规则服务名称-函数名称-触发器名称

创建完成后，您可以在函数计算控制台查看触发器信息，同时也可以在事件总线EventBridge控制台查看自动创建的资源信息。当事件源指定类型的事件投递到事件总线时，将触发该触发器关联的函数执行一次。

说明自动创建的事件总线EventBridge相关资源的名称必须符合名称取值限制和要求，否则触发器无法创建成功。具体信息，请参见使用限制。

注意事项

事件总线EventBridge限制同一地域下自定义事件总线不能超过10个，每个自定义总线上创建的事件规则总数也不能超过10个。超过以上限制的数量后，将无法再创建EventBridge触发器。
创建的消息服务MNS的队列和函数计算的函数必须在相同的地域。
MNS队列触发器暂时不支持通过Serverless Devs工具或SDK创建。

前提条件

步骤一：创建触发器

登录函数计算控制台。
在左侧导航栏，单击服务及函数。
在顶部菜单栏，选择地域。
在服务列表页面，找到目标服务，在其右侧操作列单击函数管理。
在函数管理页面，单击目标函数名称。
在函数详情页面，单击触发器管理页签，从版本或别名下拉列表选择要创建触发器的版本或别名，然后单击创建触发器。

在创建触发器面板，填写相关信息。然后单击确定。


参数	操作	本文示例
触发器类型	选择消息服务 MNS。	消息服务MNS
名称	填写自定义的触发器名称。	mns-trigger
版本或别名	默认值为LATEST，如果您需要创建其他版本或别名的触发器，首先您需要在函数详情页的右上角切换到该版本或别名。关于版本和别名的简介，请参见管理版本和管理别名。	LATEST
队列名称	选择已创建的消息服务MNS的队列。	MyQueue
调用方式	选择函数调用方式，取值说明如下：同步调用：默认调用方式，事件触发函数执行，等待函数调用完成后，函数计算返回执行结果。更多信息，请参见同步调用。异步调用：适用于调度延时较长的函数，事件触发函数执行后，函数计算立即返回响应结果并且确保函数至少被成功执行一次，但不会返回具体执行结果。更多信息，请参见异步调用。	同步调用

创建完成后，在触发器名称列表中显示已创建的触发器。

步骤二：编写函数

完成创建MNS队列触发器之后，您可以编写函数代码。

在函数详情页面，单击函数代码页签，在代码编辑器中编写代码。

代码示例如下。

'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);
  handle_event(event);
  callback(null, 'return result');
}

步骤三：测试函数

完成函数编写后，您需要调试函数以验证代码的正确性。在实际操作过程中，当消息服务MNS自定义事件源产生的事件通过事件总线EventBridge投递到函数计算时，会自动触发函数执行。

消息服务MNS事件源会以event的形式作为输入参数传递给函数，您可以手动将event传给函数模拟触发事件，测试函数代码是否正确。

在函数详情页面，单击函数代码页签，然后单击图标，从下拉列表中，选择配置测试参数。

在配置测试参数对话框，选择创建新测试事件或编辑已有测试事件页签，填写事件名称和事件内容。然后单击确定。

event是函数计算的入口参数，具体格式如下所示。

{
    "id":"c2g71017-6f65-fhcf-a814-a396fc8d****",
    "source":"MNS-Function-mnstrigger",
    "specversion":"1.0",
    "type":"mns:Queue:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
    "time":"2021-04-08T06:28:17.093Z",
    "aliyunaccountid":"1649015465574023",
    "aliyunpublishtime":"2021-10-15T07:06:34.028Z",
    "aliyunoriginalaccountid":"164901546557****",
    "aliyuneventbusname":"MNS-Function-mnstrigger",
    "aliyunregionid":"cn-chengdu",
    "aliyunpublishaddr":"42.120.XX.XX",
    "data":{
        "requestId":"606EA3074344430D4C81****",
        "messageId":"C6DB60D1574661357FA227277445****",
        "messageBody":"TEST"
    }
}

data字段包含的参数解释如下表所示。关于CloudEvents规范中定义的参数解释，请参见事件概述。


参数	类型	示例值	描述
requestId	String	606EA3074344430D4C81****	请求ID。每个请求的ID取值唯一。
messageId	String	C6DB60D1574661357FA227277445****	消息ID。每条消息的ID取值唯一。
messageBody	String	TEST	消息内容。

在函数详情页面，单击函数代码页签，然后单击测试函数。

验证结果

在函数代码页签，您可以看到执行成功的指示。