翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

チュートリアル: Amazon EventBridge サンプルアプリケーションを作成する

EventBridge を使用して、ルールを使用した特定の Lambda 関数にイベントをルーティングできます。

このチュートリアルでは、 AWS CLI、Node.js、および GitHub リポジトリのコードを使用して以下を作成します。

この例では、 AWS SAM テンプレートを使用して EventBridge ルールを定義します。EventBridge と AWS SAM テンプレートの使用の詳細については、AWS Serverless Application Model テンプレートを使用して Amazon EventBridge リソースをデプロイする を参照してください。

レポでは、atmProducer サブディレクトリに handler.js が含まれ、イベントを生成する ATM サービスを表しています。このコードは Node.js で記述された Lambda ハンドラーで、JavaScript コードのこの行を使用する AWS SDK からイベントを EventBridge に発行します。

const result = await eventbridge.putEvents(params).promise()

このディレクトリには events.js を含み、Entries 配列にいくつかのテストトランザクションをリストしています。JavaScript では、1 つのイベントは次のように定義されています。

{
  // Event envelope fields
  Source: 'custom.myATMapp',
  EventBusName: 'default',
  DetailType: 'transaction',
  Time: new Date(),

  // Main event body
  Detail: JSON.stringify({
    action: 'withdrawal',
    location: 'MA-BOS-01',
    amount: 300,
    result: 'approved',
    transactionId: '123456',
    cardPresent: true,
    partnerBank: 'Example Bank',
    remainingFunds: 722.34
  })
}

イベントの詳細セクションでは、トランザクション属性を指定します。これには ATM のロケーション、金額、パートナー銀行、取引の結果が含まれます。

atmConsumer サブディレクトリの handler.js ファイルには、3 つの関数が含まれています。

exports.case1Handler = async (event) => {
  console.log('--- Approved transactions ---')
  console.log(JSON.stringify(event, null, 2))
}

exports.case2Handler = async (event) => {
  console.log('--- NY location transactions ---')
  console.log(JSON.stringify(event, null, 2))
}

exports.case3Handler = async (event) => {
  console.log('--- Unapproved transactions ---')
  console.log(JSON.stringify(event, null, 2))
}

各関数はトランザクションイベントを受信し、console.log ステートメントから Amazon CloudWatch Logs に記録されます。コンシューマー関数はプロデューサーとは独立して動作し、イベントのソースを認識しません。

ルーティングロジックは、アプリケーションの AWS SAM テンプレートによってデプロイされる EventBridge ルールに含まれています。ルールは、イベントの受信ストリームを評価し、一致するイベントをターゲットの Lambda 関数にルーティングします。

ルールでは、一致するイベントと同じ構造の JSON オブジェクトであるイベントパターンを使用します。ルールの 1 つのイベントパターンを次に示します。

{
  "detail-type": ["transaction"],
  "source": ["custom.myATMapp"],
  "detail": {
    "location": [{
      "prefix": "NY-"
    }]
  }
}

前提条件

このチュートリアルを完了するには、以下のリソースが必要です。

ステップ 1: アプリケーションを作成する

サンプルアプリケーションを設定するには、 AWS CLI と Git を使用して必要な AWS リソースを作成します。

ステップ 2: アプリケーションを実行する

これでリソースが設定されたので、コンソールを使用して関数をテストします。

ステップ 3: ログを確認し、アプリケーションが動作することを検証する

これでアプリケーションが実行されたので、コンソールを使用して CloudWatch Logs を確認します。

ステップ 4: リソースをクリーンアップする

このチュートリアル用に作成したリソースは、保持しない場合は削除できます。使用しなくなった AWS リソースを削除することで、 AWS アカウントへの不要な課金を防ぐことができます。