使用Node.js请求处理程序响应事件并执行相关业务代码 - 函数计算

本文介绍Node.js事件请求处理程序的结构特点和示例。

Event Handler签名

说明

函数计算从Node.js 18运行时开始支持ECMAScript（ES）模块。在此之前（Node.js 16及以前的版本），函数计算仅支持使用CommonJS 模块。详情请参见将请求处理程序指定为ES模块。

一个简单的Event Handler签名定义如下。

Node.js 18及以上版本

ES模块

// index.mjs
export const handler = async (event, context) => {
  console.log("event: \n" + event);
  return "Hello World!";
};

CommonJS模块

// index.js
exports.handler = async function(event, context) {
  console.log("event: \n" + event);
  return "Hello World!";
};

Node.js 16及以下版本

// index.js
exports.handler = async function(event, context, callback) {
  console.log("event: \n" + event);
  callback(null, 'hello world');
};

Event Handler的示例解析如下：

handler是方法名称，与函数计算控制台配置的请求处理程序相对应。例如，创建函数时指定的请求处理程序为index.handler，那么函数计算会去加载index.js中定义的handler函数，并从这里开始执行。

函数计算运行时会将请求参数传递到请求处理程序中，第一个参数是event对象，包含请求的有效负载信息，event对象是Buffer类型，您可以将其转换成所需要的对象类型。第二个参数是 context对象，提供在调用时的运行上下文信息。更多信息，请参见上下文。

说明

使用Node.js 18及以上版本的运行时环境时，建议您使用Async/Await功能，而不是使用回调函数callback。
函数计算会根据返回值的类型对返回结果做相应转换。
- Buffer类型：不转换，原样返回。
- Object类型：转换为JSON格式后返回。
- 其他类型：转换为字符串后返回。

Async/Await

使用Node.js 18及以上版本的运行时环境时，建议您使用Async/Await方式来实现。Async/Await是一种简洁、易读的Node.js异步代码编写方式，无需嵌套回调或链式调用。

重要

如果您使用的Node.js 16及以下版本的运行时环境，则必须显式使用回调方法 callback发送响应，否则会出现请求超时错误。

Async/Await方式与回调函数callback相比，有以下优点：

可读性更好：Async/Await方式的代码更加线性和同步，更易于理解和维护。它避免了回调函数嵌套过深的情况，使代码结构更清晰。
调试和错误处理更简单：可以使用try-catch块更方便地捕获和处理异步操作中的错误，错误堆栈更加清晰，可以更准确地追踪错误发生的位置。
效率更高：回调函数通常需要在代码的不同部分之间切换。Async/Await方式可以减少上下文切换的数量，从而提高代码效率。

示例一：解析JSON格式参数

示例代码

当您传入JSON格式参数时，函数计算会透传参数内容，需要您在代码中自行解析。下面是解析JSON格式事件的代码示例。

ES模块

说明

此示例仅支持运行在Node.js 18及以上版本的运行时环境。

export const handler = async (event, context) => {
  var eventObj = JSON.parse(event.toString());
  return eventObj['key'];
};

CommonJS模块

exports.handler = function(event, context, callback) {
  var eventObj = JSON.parse(event.toString());
  callback(null, eventObj['key']);
};

前提条件

已创建Node.js函数，具体操作，请参见创建函数。如果您需要将代码指定为ES模块，创建函数时，运行环境需选择Node.js 18或Node.js 20。

操作步骤

登录函数计算控制台，在左侧导航栏，单击服务及函数。
在顶部菜单栏，选择地域，然后在服务列表页面，单击目标服务。
在函数管理页面，单击目标函数名称，然后在函数详情页面，单击函数代码页签。
在函数代码页签，在代码编辑器中输入上述示例代码，然后单击部署代码。
说明
上述示例代码中函数的请求处理程序是index.js或index.mjs中的handler方法。如果您的函数的请求处理程序配置不同，请获取对应的文件和方法进行更新。
在函数代码页签，单击测试函数右侧的图标，从下拉列表中选择配置测试参数，输入如下示例测试参数，然后单击确定。
```
{
  "key": "value"
}
```
单击测试函数。
函数执行成功后，查看返回结果，您可以看到返回结果为value。

示例二：通过临时密钥安全读写OSS的资源

示例代码

您可以使用函数计算为您提供的临时密钥访问对象存储OSS，代码示例如下所示。

ES模块

说明

此示例仅支持运行在Node.js 18及以上版本的运行时环境。

// index.mjs
import OSSClient from 'ali-oss';

export const handler = async (event, context) => {
    console.log(event.toString());

    var ossClient = new OSSClient({
        accessKeyId: context.credentials.accessKeyId,
        accessKeySecret: context.credentials.accessKeySecret,
        stsToken: context.credentials.securityToken,
        region: 'oss-cn-shenzhen',
        bucket: 'my-bucket',
    });

    try {
      // 上传文件到OSS，'object'是OSS中的文件名，'localfile'是本地文件的路径。
      const uploadResult = await ossClient.put('myObj', Buffer.from('hello, fc', "utf-8"));
      console.log('upload success, ', uploadResult);
      return "succ"
    } catch (error) {
      throw error
    }
};

代码示例解析：

context.credentials：从 context 参数中获取临时密钥，避免在代码中硬编码密码等敏感信息。
myObj：OSS对象名。
Buffer.from('hello, fc', "utf-8")：上传的对象内容。
return "succ"：上传成功正常返回 "succ"。
throw err：上传失败时抛出异常。

CommonJS模块

var OSSClient = require('ali-oss');

exports.handler = function (event, context, callback) {
    console.log(event.toString());

    var ossClient = new OSSClient({
        accessKeyId: context.credentials.accessKeyId,
        accessKeySecret: context.credentials.accessKeySecret,
        stsToken: context.credentials.securityToken,
        region: 'oss-cn-shenzhen',
        bucket: 'my-bucket',
    });

    ossClient.put('myObj', Buffer.from('hello, fc', "utf-8")).then(function (res) {
        callback(null, 'succ');
    }).catch(function (err) {
        callback(err);
    });
};

代码示例解析：

context.credentials：从context参数中获取临时密钥，避免在代码中硬编码密码等敏感信息。
myObj：OSS对象名。
Buffer.from('hello, fc', "utf-8")：上传的对象内容。
callback(null, 'put object')：上传成功正常返回"succ"。
callback(err)：上传失败时异常返回err。

前提条件

为服务配置具有访问对象存储OSS的权限的角色。具体操作，请参见授予函数计算访问其他云服务的权限。
创建运行环境为Node.js的函数。具体操作，请参见创建函数。如果您需要将代码指定为ES模块，创建函数时，运行环境需选择Node.js 18或Node.js 20。

操作步骤

登录函数计算控制台，在左侧导航栏，单击服务及函数。
在顶部菜单栏，选择地域，然后在服务列表页面，单击目标服务。
在函数管理页面，单击目标函数名称，然后在函数详情页面，单击函数代码页签。
（可选）在函数代码页签，在下方的WebIDE界面，依次选择Terminal > New Terminal打开终端，执行以下命令安装ali-oss依赖。
```
npm install ali-oss --save
```
安装完成后，在WebIDE界面左侧代码目录可以看到生成了node_modules文件夹，文件夹内包含ali-oss目录以及其他依赖库。
在函数代码页签，在下面代码编辑器中，输入上述示例代码，保存并单击部署代码。
说明
- 上述示例代码中函数的请求处理程序是index.js或index.mjs中的handler方法。如果您的函数的请求处理程序配置不同，请获取对应的文件和方法进行更新。
- 上述示例代码中region和bucket需按照实际情况填写。
单击测试函数。
函数执行成功后，查看返回结果，您可以看到返回结果为succ。

示例三：调用外部命令

您的Node.js程序也可以创建fork进程，调用外部命令。例如，您可以使用child_process模块调用Linux的ls -l命令，输出当前目录下的文件列表。代码示例如下：

ES模块

说明

此示例仅支持运行在Node.js 18及以上版本的运行时环境。

import { exec } from 'child_process';
import { promisify } from 'util';

const execPromisify = promisify(exec);
export const handler = async (event, context) => {
  try {
    const { stdout, stderr } = await execPromisify("ls -l");
    console.log(`stdout: ${stdout}`);
    if (stderr !== "") {
      console.error(`stderr: ${stderr}`);
    }
    return stdout;
  } catch (error) {
    console.error(`exec error: ${error}`);
    return error;
  }
}

CommonJS模块

'use strict';

var exec = require('child_process').exec;
exports.handler = (event, context, callback) => {
  console.log('start to execute a command');
  exec("ls -l", function(error, stdout, stderr){
    callback(null, stdout);
});
}