Step Functions ワークフローで並列タスクを定義する

新しいタブまたはウィンドウで、Lambda コンソールを開き、 と というタイトルの 2 つの Node.js Lambda check-identity 関数を作成しますcheck-address。コンソールを使用した Lambda 関数の作成については、「AWS Lambda デベロッパーガイド」の「コンソールで Lambda の関数の作成」を参照してください。

[check-identity] 関数ページを開き、[コードソース] 領域の既存のコードを次のコードに置き換えます。

const ssnRegex = /^\d{3}-?\d{2}-?\d{4}$/;
const emailRegex = /^[a-zA-Z0-9._-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,4}$/;

class ValidationError extends Error {
    constructor(message) {
        super(message);
        this.name = "CustomValidationError";
    }
}

exports.handler = async (event) => {
    const {
        ssn,
        email
    } = event;
    console.log(`SSN: ${ssn} and email: ${email}`);

    const approved = ssnRegex.test(ssn) && emailRegex.test(email);

    if (!approved) {
        throw new ValidationError("Check Identity Validation Failed");
    }

    return {
        statusCode: 200,
        body: JSON.stringify({
            approved,
            message: `Identity validation ${approved ? 'passed' : 'failed'}`
        })
    }
};

[check-address] 関数ページを開き、[コードソース] 領域の既存のコードを次のコードに置き換えます。

class ValidationError extends Error {
  constructor(message) {
      super(message);
      this.name = "CustomAddressValidationError";
  }
}

exports.handler = async event => {
  const {
      street,
      city,
      state,
      zip
  } = event;
  console.log(`Address information: ${street}, ${city}, ${state} - ${zip}`);

  const approved = [street, city, state, zip].every(i => i?.trim().length > 0);

  if (!approved) {
      throw new ValidationError("Check Address Validation Failed");
  }

  return {
      statusCode: 200,
      body: JSON.stringify({
          approved,
          message: `Address validation ${ approved ? 'passed' : 'failed'}`
      })
  }
};

両方の Lambda 関数について、関数の概要セクションからそれぞれの Amazon リソースネーム (ARN) をコピーし、テキストファイルに保存します。申請者の ID と住所の検証状態のサービス統合を指定するARNsときに、 関数が必要です。 の例を次に示しますARN。

arn:aws:lambda:us-east-2:123456789012:function:HelloWorld

Step Functions でステートマシンを作成する で作成したワークフロープロトタイプを含む、Step Functions コンソールウィンドウを開きます。

[ID の検証] 状態を選択し、[構成]タブで次の操作を行います。

1. [統合タイプ] は、デフォルトの [最適化] のままにします。

   注記

   Step Functions を使用すると、他の と統合し AWS サービス 、ワークフローでオーケストレーションできます。サービス統合とタイプの詳細については、「他の サービスと Step Functions の統合」を参照してください。

2. [関数名] には、ドロップダウンリストから [check-identity] Lambda 関数を選択します。

3. [ペイロード] には、[ペイロードを入力] を選択し、サンプルのペイロードを次のものに置き換えます。

   {
       "email": "janedoe@example.com",
       "ssn": "012-00-0000"
   }

[住所の確認] 状態を選択し、[構成]タブで次の操作を行います。

1. [統合タイプ] は、デフォルトの [最適化] のままにします。

2. [関数名] には、ドロップダウンリストから [check-address] Lambda 関数を選択します。

3. [ペイロード] には、[ペイロードを入力] を選択し、サンプルのペイロードを次のものに置き換えます。

   {
       "street": "123 Any St",
       "city": "Any Town",
       "state": "AT",
       "zip": "01000"
   }

[Next (次へ)] を選択します。