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

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

创建 Amazon EventBridge 示例应用程序

您可以使用 EventBridge，通过规则将事件路由到特定 Lambda 函数。

在本教程中，您将使用 Amazon CLI、Node.js 和 GitHub 存储库中的代码来创建以下内容：

此示例使用 Amazon SAM 模板来定义 EventBridge 规则。要了解有关如何在 EventBridge 中使用 Amazon SAM 模板的更多信息，请参阅 使用 Amazon EventBridge 和 Amazon Serverless Application Model 模板。

在存储库中，atmProducer 子目录包含 handler.js，代表生成事件的 ATM 服务。这段代码是用 Node.js 编写的 Lambda 处理程序，它使用这行 JavaScript 代码通过 Amazon 开发工具包将事件发布到 EventBridge。

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

此目录还包含 events.js，在条目数组中列出了几个测试交易。在 JavaScript 中，单个事件的定义如下：

{
  // 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
  })
}

事件的 Detail 部分指定了交易属性。其中包括 ATM 的位置、金额、合作银行和交易结果。

atmConsumer 子目录中的 handler.js 文件包含三个函数：

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 中。消费者函数独立于生产者运行，它们不知道事件的源。

路由逻辑包含在 EventBridge 规则中，这些规则由应用程序的 Amazon SAM 模板部署。这些规则会评估传入的事件流，并将匹配的事件路由到目标 Lambda 函数。

这些规则使用的事件模式是 JSON 对象，与它们匹配的事件具有相同的结构。以下是其中一条规则的事件模式。

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

先决条件

完成本教程需要以下资源：

步骤 1：创建应用程序

要设置示例应用程序，您需要使用 Amazon CLI 和 Git 来创建所需的 Amazon 资源。

步骤 2：运行应用程序

您已设置资源，现在可以利用控制台测试功能。

步骤 3：检查日志并验证应用程序运行是否正常

现在，应用程序已运行，您将使用控制台查看 CloudWatch Logs。

步骤 4：清理资源

除非您想要保留为本教程创建的资源，否则可立即将其删除。请删除您不再使用的 Amazon 资源，这样可防止您的 Amazon 账户产生不必要的费用。