Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon SDK for JavaScript V3 API 参考指南详细描述了 Amazon SDK for JavaScript 版本 3 (V3) 的所有API操作。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

使用网关调用 Lambda API

您可以使用 Amazon API Gateway 调用 Lambda 函数，这是一项用于大规模创建、发布、维护RESTHTTP、监控和保护 WebSocket APIs的 Amazon 服务。API开发人员可以创建APIs该访问权限 Amazon 或其他 Web 服务，以及存储在 Amazon 云中的数据。作为 API Gateway 开发人员，您可以创建APIs以在自己的客户端应用程序中使用。有关更多信息，请参阅什么是 Amazon API Gateway。

Amazon Lambda 是一项计算服务，使您无需预置或管理服务器即可运行代码。您可以使用各种编程语言创建 Lambda 函数。有关的更多信息 Amazon Lambda，请参阅什么是 Amazon Lambda。

在此示例中，您将使用 Lambda 运行时创建一个 Lambda 函数。 JavaScript API此示例调用不同的 Amazon 服务来执行特定的用例。例如，假设组织在员工入职一周年纪念日时向员工发送移动短信表示祝贺，如下图所示。

完成此示例大约需要 20 分钟。

此示例向您展示如何使用 JavaScript 逻辑来创建执行此用例的解决方案。例如，您将学习如何使用 Lambda 函数读取数据库以确定哪些员工已达到入职一周年纪念日、如何处理数据以及如何发送短信。然后，您将学习如何使用 API Gateway 通过 Rest 端点调用此 Amazon Lambda 函数。例如，您可以使用以下 curl 命令调用 Lambda 函数：

curl -XGET "https://xxxxqjko1o3.execute-api.us-east-1.amazonaws.com/cronstage/employee" 

本 Amazon 教程使用名为 Employee 的 Amazon DynamoDB 表，其中包含这些字段。

完成先决条件任务

要设置和运行此示例，您必须先完成以下任务：

创建 Amazon 资源

本教程要求具有以下资源:

您可以手动创建这些资源，但我们建议 Amazon CloudFormation 按照本教程中的说明使用配置这些资源。

使用创建 Amazon 资源 Amazon CloudFormation

Amazon CloudFormation 使您能够以可预测的方式重复创建和配置 Amazon 基础架构部署。有关的更多信息 Amazon CloudFormation，请参阅《Amazon CloudFormation 用户指南》。

要使用以下方法创建 Amazon CloudFormation 堆栈 Amazon CLI：

填充表

要填充表，请先创建一个名为 libs 的目录，然后在其中创建一个名为 dynamoClient.js 的文件，再将下面的内容粘贴到其中。

const { DynamoDBClient } = require ( "@aws-sdk/client-dynamodb" );
// Set the AWS Region.
const REGION = "REGION"; // e.g. "us-east-1"
 // Create an Amazon Lambda service client object.
const dynamoClient = new DynamoDBClient({region:REGION});
module.exports = { dynamoClient };
                

此代码可从此处获得 GitHub。

接下来，在项目文件夹的根目录populate-table.js中创建一个名为的文件，然后将此处的内容复制 GitHub到其中。对于其中一项，将 phone 属性的值替换为 E.164 格式的有效手机号码，将 startDate 的值替换为今天的日期。

在命令行处，运行以下命令。

node populate-table.js

const { BatchWriteItemCommand } = require ( "aws-sdk/client-dynamodb" );
const {dynamoClient} = require ( "./libs/dynamoClient" );

// Set the parameters.
export const params = {
  RequestItems: {
    Employees: [
      {
        PutRequest: {
          Item: {
            id: { N: "1" },
            firstName: { S: "Bob" },
            phone: { N: "155555555555654" },
            startDate: { S: "2019-12-20" },
          },
        },
      },
      {
        PutRequest: {
          Item: {
            id: { N: "2" },
            firstName: { S: "Xing" },
            phone: { N: "155555555555653" },
            startDate: { S: "2019-12-17" },
          },
        },
      },
      {
        PutRequest: {
          Item: {
            id: { N: "55" },
            firstName: { S: "Harriette" },
            phone: { N: "155555555555652" },
            startDate: { S: "2019-12-19" },
          },
        },
      },
    ],
  },
};

export const run = async () => {
  try {
    const data = await dbclient.send(new BatchWriteItemCommand(params));
    console.log("Success", data);
  } catch (err) {
    console.log("Error", err);
  }
};
run();

此代码可从此处获得 GitHub。

创建 Amazon Lambda 函数

正在配置 SDK

在 libs 目录中，创建名为 snsClient.js 和 lambdaClient.js 的文件，并将以下内容分别粘贴到这些文件中。

const { SNSClient } = require("@aws-sdk/client-sns");
// Set the AWS Region.
const REGION = "REGION"; //e.g. "us-east-1"
// Create an Amazon SNS service client object.
const snsClient = new SNSClient({ region: REGION });
module.exports = { snsClient };

Replace（替换） REGION 与该 Amazon 地区合作。此代码可从此处获得 GitHub。

const { LambdaClient } = require("@aws-sdk/client-lambda");
// Set the AWS Region.
const REGION = "REGION"; //e.g. "us-east-1"
// Create an Amazon Lambda service client object.
const lambdaClient = new LambdaClient({ region: REGION });
module.exports = { lambdaClient };

Replace（替换） REGION 与该 Amazon 地区合作。此代码可从此处获得 GitHub。

首先，导入所需的 Amazon SDK for JavaScript (v3) 模块和命令。然后计算今天的日期并将其分配给一个参数。然后，为 ScanCommand 创建参数。Replace（替换） TABLE_NAME 使用您在本示例创建 Amazon 资源 部分中创建的表的名称。

下面的代码段演示了此步骤。（有关完整示例，请参阅捆绑 Lambda 函数。）

const { ScanCommand } = require("@aws-sdk/client-dynamodb");
const { PublishCommand } = require("@aws-sdk/client-sns");
const { snsClient } = require("./libs/snsClient");
const { dynamoClient } = require("./libs/dynamoClient");

// Get today's date.
const today = new Date();
const dd = String(today.getDate()).padStart(2, "0");
const mm = String(today.getMonth() + 1).padStart(2, "0"); //January is 0!
const yyyy = today.getFullYear();
const date = `${yyyy}-${mm}-${dd}`;

// Set the parameters for the ScanCommand method.
const params = {
  // Specify which items in the results are returned.
  FilterExpression: "startDate = :topic",
  // Define the expression attribute value, which are substitutes for the values you want to compare.
  ExpressionAttributeValues: {
    ":topic": { S: date },
  },
  // Set the projection expression, which are the attributes that you want.
  ProjectionExpression: "firstName, phone",
  TableName: "Employees",
};

扫描 DynamoDB 表

首先，创建一个名为 async/await 函数sendText，用于使用 Amazon 发布短信。SNS PublishCommand然后，添加一个 try 块模式，用于扫描 DynamoDB 表中是否有工作周年纪念日在今天的员工，然后调用 sendText 函数向这些员工发送短信。如果发生错误，则将调用 catch 块。

下面的代码段演示了此步骤。（有关完整示例，请参阅捆绑 Lambda 函数。）

// Helper function to send message using Amazon SNS.
exports.handler = async () => {
  // Helper function to send message using Amazon SNS.
  async function sendText(textParams) {
    try {
      await snsClient.send(new PublishCommand(textParams));
      console.log("Message sent");
    } catch (err) {
      console.log("Error, message not sent ", err);
    }
  }
  try {
    // Scan the table to identify employees with work anniversary today.
    const data = await dynamoClient.send(new ScanCommand(params));
    for (const element of data.Items) {
      const textParams = {
        PhoneNumber: element.phone.N,
        Message: `Hi ${element.firstName.S}; congratulations on your work anniversary!`,
      };
      // Send message using Amazon SNS.
      sendText(textParams);
    }
  } catch (err) {
    console.log("Error, could not scan table ", err);
  }
};

捆绑 Lambda 函数

本主题介绍如何将本示例的模块mylambdafunction.ts和必需的 Amazon SDK for JavaScript 模块捆绑到名index.js为的捆绑文件中。

部署 Lambda 函数

在项目的根目录中，创建一个 lambda-function-setup.ts 文件，然后将以下内容粘贴到其中。

Replace（替换） BUCKET_NAME 使用您将 Lambda 函数ZIP版本上传到的 Amazon S3 存储桶的名称。Replace（替换） ZIP_FILE_NAME 使用名称命名您的 Lambda 函数的ZIP版本。Replace（替换） ROLE 使用您在本教程创建 Amazon 资源 主题中创建的IAM角色的 Amazon 资源编号 (ARN)。Replace（替换） LAMBDA_FUNCTION_NAME 带有 Lambda 函数的名称。

// Load the required Lambda client and commands.
const {
  CreateFunctionCommand
} = require ( "@aws-sdk/client-lambda" );
const { lambdaClient} = require ( "./libs/lambdaClient.js );

// Set the parameters.
const params = {
  Code: {
    S3Bucket: "BUCKET_NAME", // BUCKET_NAME
    S3Key: "ZIP_FILE_NAME", // ZIP_FILE_NAME
  },
  FunctionName: "LAMBDA_FUNCTION_NAME",
  Handler: "index.handler",
  Role: "IAM_ROLE_ARN", // IAM_ROLE_ARN; e.g., arn:aws:iam::650138640062:role/v3-lambda-tutorial-lambda-role
  Runtime: "nodejs12.x",
  Description:
    "Scans a DynamoDB table of employee details and using Amazon Simple Notification Services (Amazon SNS) to " +
    "send employees an email on each anniversary of their start-date.",
};

const run = async () => {
  try {
    const data = await lambdaClient.send(new CreateFunctionCommand(params));
    console.log("Success", data); // successful response
  } catch (err) {
    console.log("Error", err); // an error occurred
  }
};
run();

在命令行中输入以下内容以部署 Lambda 函数。

node lambda-function-setup.ts

此代码示例可在此处找到 GitHub。

将API网关配置为调用 Lambda 函数

创建其余的 API

您可以使用API网关控制台为 Lambda 函数创建休息终端节点。完成后，您就可以使用 restful 调用来调用 Lambda 函数。

测试网API关方法

在本教程中，您可以测试调用 my lambdafunction Lambda 函数的 API Gateway 方法。要测试该方法，请选择测试，如下图所示。

调用 Lambda 函数后，您可以查看日志文件以查看成功消息。

部署网API关方法

测试成功后，您可以从 Amazon API Gateway 控制台部署该方法。

删除资源

恭喜您！您已使用 Amazon Gate API way 调用了 Lambda 函数。 Amazon SDK for JavaScript如本教程开头所述，请务必在学习本教程时终止您创建的所有资源，以确保系统不会向您收费。您可以通过删除在本教程创建 Amazon 资源 主题中创建的 Amazon CloudFormation 堆栈来实现此目的，如下所示：