MQTT触发器

背景信息

您在函数计算的控制台提交触发器创建请求后，函数计算会根据触发器的配置信息，自动在事件总线EventBridge侧创建事件流资源。

创建完成后，您可以在函数计算控制台查看触发器信息，同时也可以在事件总线EventBridge控制台查看自动创建的资源信息。当云消息队列 MQTT 版中有消息入队时，将会触发函数计算执行，触发时会根据您的攒批配置将一个或多个消息事件以批的形式推送到函数中进行处理。

使用限制

• 作为触发源的云消息队列 MQTT 版实例必须和函数计算的函数在相同的地域。

• 创建的事件流数量超过上限后，将无法再创建MQTT触发器。关于事件流数量的限制，请参见使用限制。

步骤一：创建MQTT触发器

1. 登录函数计算控制台，在左侧导航栏，单击服务及函数。
2. 在顶部菜单栏，选择地域，然后在服务列表页面，单击目标服务。
3. 在函数管理页面，单击目标函数名称。

4. 在函数详情页面，单击触发器管理页签，从版本或别名下拉列表选择要创建触发器的版本或别名，然后单击创建触发器。

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

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

   关于推送配置、重试和死信等高级配置项说明，请参见触发器高级功能。

   创建完成后，在触发器管理页签下会显示已创建的触发器。如果需要对创建的触发器进行修改或删除，请参见触发器管理。

步骤二：配置函数入口参数

MQTT事件源会以event的形式作为输入参数传递给函数，您可以手动将event传给函数模拟触发事件。

步骤三：编写函数代码并测试

触发器创建完成后，您可以开始编写并测试函数代码，以验证代码的正确性。在实际操作过程中，当云消息队列 MQTT 版接收到消息后，触发器会自动触发函数执行。

1. 在函数详情页面，单击函数代码页签，在代码编辑器中编写代码，然后单击部署代码。

   本文以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');
   }

2. 单击函数代码页签的测试函数。
   执行完成后，您可以在函数代码页签的上方查看执行结果。

更多信息

除了函数计算控制台，您还可以通过以下方式配置触发器：

• 通过Serverless Devs工具配置触发器。更多操作，请参见创建触发器。

• 通过SDK配置触发器。更多操作，请参见SDK列表。

如需对创建的触发器进行修改或删除，具体操作，请参见触发器管理。