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

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

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

使用 Amazon SDK for JavaScript 创建 Amazon 无服务器工作流

您可以通过对 Amazon SDK for Java 和 Amazon Step Functions 使用 Step Functions 来创建 Amazon 无服务器工作流。每个工作流步骤都通过使用 Amazon Lambda 函数实现。Lambda 是一项计算服务，使您无需预置或管理服务器即可运行代码。Step Functions 是一项无服务器编排服务，可让您搭配使用 Lambda 函数和其他 Amazon 服务来构建业务关键型应用程序。

在本教程中，您将创建一个工作流，为组织创建支持工单。每个工作流步骤都会对工单执行一项操作。本教程介绍如何使用 JavaScript 处理工作流数据。例如，您将学习如何读取传递给工作流的数据，如何在步骤之间传递数据，以及如何从工作流调用 Amazon 服务。

完成费用：本文档中包含的 Amazon 服务包含在 Amazon 免费套餐中。

注意：在学习本教程时，请务必终止您创建的所有资源，以确保系统不再向您收费。

先决条件任务

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

创建 Amazon 资源

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

您可以手动创建这些资源，但我们建议使用本教程中所述的 Amazon Cloud Development Kit (Amazon CDK) (Amazon CDK) 预置这些资源。

使用 Amazon CloudFormation 创建 Amazon 资源

Amazon CloudFormation 让您能够以可预测、可重复的方式创建和预置 Amazon 基础设施部署。有关 Amazon CloudFormation 的更多信息，请参阅 Amazon CloudFormation 用户指南。

创建 Amazon CloudFormation 堆栈：

使用 Amazon Web Services 管理控制台创建 Amazon 资源；

要在控制台中为应用程序创建资源，请按照 Amazon CloudFormation 用户指南中的说明进行操作。使用提供的模板创建一个名为 setup.yaml 的文件，然后复制 GitHub 上此处的内容。

在 Amazon CloudFormation 仪表板上打开堆栈，然后选择资源选项卡，即可在控制台中查看资源列表。您将在本教程中需要这些内容。

创建工作流

下图显示了您将使用本教程创建的工作流。

以下是工作流中每个步骤中发生的情况：

+ 开始 - 启动工作流。

+ 开立案例 - 通过将支持工单 ID 值传递给工作流来处理该值。

+ 分配案例 - 将支持案例分配给员工，并将数据存储在 DynamoDB 表中。

+ 发送电子邮件 - 使用 Amazon Simple Email Service (Amazon SES) 向员工发送一封电子邮件，告知他们有一张新工单。

+ 结束 - 停止工作流。

使用 Step Functions 创建无服务器工作流

您可以创建处理支持工单的工作流。要使用 Step Functions 定义工作流，您需要创建一个 Amazon States Language（基于 JSON）文档来定义您的状态机。Amazon States Language 文档描述了每个步骤。定义文档后，Step Functions 将提供工作流的可视化表示。下图显示了 Amazon States Language 文档和工作流的可视化表示。

工作流可以在步骤之间传递数据。例如，开立案例步骤处理案例 ID 值（该值传递给工作流），并将该值传递给分配案例步骤。在本教程的后面部分，您将使用 Lambda 函数创建应用程序逻辑来读取和处理数据值。

创建工作流

创建 Lambda 函数

使用 Lambda 运行时系统 API 创建 Lambda 函数。在此示例中，有三个工作流步骤，每个步骤对应于每个 Lambda 函数。

创建这些 Lambda 函数，如以下部分所述：

getId Lambda 函数

创建一个 Lambda 函数，该函数返回的工单 ID 值将传递至工作流的第二步。

exports.handler = async (event) => {
// Create a support case using the input as the case ID, then return a confirmation message
try{
    const myCaseID = event.inputCaseID;
    var myMessage = "Case " + myCaseID + ": opened...";
    var result = { Case: myCaseID, Message: myMessage };
   }
catch(err){
    console.log('Error', err);
   }
};

在命令行中输入以下内容，以使用 webpack 将文件捆绑到名为 index.js 的文件中。

webpack getid.js --mode development --target node --devtool false --output-library-target umd -o index.js

然后将 index.js 压缩为一个名为 getid.js.zip 的 ZIP 文件。将此 ZIP 文件上传到您在此示例的主题中创建的 Amazon S3 存储桶。

GitHub 的此处提供了此代码示例。

addItem Lambda 类

创建一个 Lambda 函数，用于选择要分配工单的员工，然后将工单数据存储在名为 Case 的 DynamoDB 表中。

"use strict";
// Load the required clients and commands.
const { PutItemCommand } = require ( "@aws-sdk/client-dynamodb" );
const { dynamoClient } = require ( "../libs/dynamoClient" );

exports.handler = async (event) => {
  try {
    // Helper function to send message using Amazon SNS.
    const val = event;
    //PersistCase adds an item to a DynamoDB table
    const tmp = Math.random() <= 0.5 ? 1 : 2;
    console.log(tmp);
    if (tmp == 1) {
      const params = {
        TableName: "Case",
        Item: {
          id: { N: val.Case },
          empEmail: { S: "brmur@amazon.com" },
          name: { S: "Tom Blue" },
        },
      };
      console.log("adding item for tom");
      try {
        const data = await dynamoClient.send(new PutItemCommand(params));
        console.log(data);
      } catch (err) {
        console.error(err);
      }
      var result = { Email: params.Item.empEmail };
      return result;
    } else {
      const params = {
        TableName: "Case",
        Item: {
          id: { N: val.Case },
          empEmail: { S: "RECEIVER_EMAIL_ADDRESS" }, // Valid Amazon Simple Notification Services (Amazon SNS) email address.
          name: { S: "Sarah White" },
        },
      };
      console.log("adding item for sarah");
      try {
        const data = await dynamoClient.send(new PutItemCommand(params));
        console.log(data);
      } catch (err) {
        console.error(err);
      }
      return params.Item.empEmail;
      var result = { Email: params.Item.empEmail };
    }
  } catch (err) {
    console.log("Error", err);
  }
};

在命令行中输入以下内容，以使用 webpack 将文件捆绑到名为 index.js 的文件中。

webpack additem.js --mode development --target node --devtool false --output-library-target umd -o index.js

然后将 index.js 压缩为一个名为 additem.js.zip 的 ZIP 文件。将此 ZIP 文件上传到您在此示例的主题中创建的 Amazon S3 存储桶。

GitHub 的此处提供了此代码示例。

sendemail Lambda 类

创建一个 Lambda 函数，用于向员工发送电子邮件以告知有关新工单的信息。将使用从第二步中传递的电子邮件地址。

// Load the required clients and commands.
const { SendEmailCommand } = require ( "@aws-sdk/client-ses" );
const { sesClient } = require ( "../libs/sesClient" );

exports.handler = async (event) => {
  // Enter a sender email address. This address must be verified.
  const senderEmail = "SENDER_EMAIL"
  const sender = "Sender Name <" + senderEmail + ">";

  // AWS Step Functions passes the  employee's email to the event.
  // This address must be verified.
  const recepient = event.S;

  // The subject line for the email.
  const subject = "New case";

  // The email body for recipients with non-HTML email clients.
  const body_text =
    "Hello,\r\n" + "Please check the database for new ticket assigned to you.";

  // The HTML body of the email.
  const body_html = `<html><head></head><body><h1>Hello!</h1><p>Please check the database for new ticket assigned to you.</p></body></html>`;

  // The character encoding for the email.
  const charset = "UTF-8";
  var params = {
    Source: sender,
    Destination: {
      ToAddresses: [recepient],
    },
    Message: {
      Subject: {
        Data: subject,
        Charset: charset,
      },
      Body: {
        Text: {
          Data: body_text,
          Charset: charset,
        },
        Html: {
          Data: body_html,
          Charset: charset,
        },
      },
    },
  };
  try {
    const data = await sesClient.send(new SendEmailCommand(params));
    console.log(data);
  } catch (err) {
    console.error(err);
  }
};

在命令行中输入以下内容，以使用 webpack 将文件捆绑到名为 index.js 的文件中。

webpack sendemail.js --mode development --target node --devtool false --output-library-target umd -o index.js

然后将 index.js 压缩为一个名为 sendemail.js.zip 的 ZIP 文件。将此 ZIP 文件上传到您在此示例的主题中创建的 Amazon S3 存储桶。

GitHub 的此处提供了此代码示例。

部署 Lambda 函数

部署 getid Lambda 函数：

将 Lambda 函数添加到工作流

使用 Step Functions 控制台执行工作流

您可以在 Step Functions 控制台上调用工作流。执行会接收 JSON 输入。在此示例中，您可以将以下 JSON 数据传递到工作流。

{
"inputCaseID": "001"
}

执行您的工作流：

删除 Amazon 资源

恭喜，您已经使用 Amazon SDK for Java 创建了一个 Amazon 无服务器工作流。如本教程开头所述，请务必在学习本教程时终止您创建的所有资源，以确保系统不会向您收费。您可以通过删除在本教程的创建 Amazon 资源 主题中创建的 Amazon CloudFormation 堆栈来实现此目的，方法如下所示：