Tutorial: Creación de una aplicación de muestra de Amazon EventBridge

Puede usar EventBridge para enrutar eventos a funciones de Lambda específicas mediante reglas.

En este tutorial, usará la AWS CLI, Node.js, y el código del repositorio de GitHub para crear lo siguiente:

En este ejemplo, se utilizan plantillas de AWS SAM para definir las reglas de EventBridge. Para obtener más información sobre el uso de plantillas de AWS SAM con EventBridge, consulte Uso de plantillas de AWS Serverless Application Model para implementar los recursos de Amazon EventBridge.

En el repositorio, el subdirectorio atmProducer contiene handler.js, que representa el servicio de cajero automático que produce eventos. Este código es un controlador de Lambda escrito en Node.js y publica eventos en EventBridge a través del SDK de AWS mediante esta línea de código JavaScript.

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

Este directorio también contiene events.js, una lista de varias transacciones de prueba en una matriz de entradas. Un único evento se define en JavaScript de la siguiente manera:

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

La sección Detalle del evento especifica los atributos de la transacción. Incluyen la ubicación del cajero automático, el importe, el banco asociado y el resultado de la transacción.

El archivo handler.js del subdirectorio atmConsumer contiene tres funciones:

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

Cada función recibe eventos de transacciones, que se registran a través de las instrucciones de console.log en Registros de Amazon CloudWatch. Las funciones de consumo funcionan de forma independiente del productor y desconocen el origen de los eventos.

La lógica de enrutamiento está incluida en las reglas de EventBridge que implementa la plantilla de AWS SAM de la aplicación. Las reglas evalúan el flujo entrante de eventos y enrutan los eventos coincidentes a las funciones de Lambda de destino.

Las reglas utilizan patrones de eventos que son objetos JSON con la misma estructura que los eventos con los que coinciden. Este es el patrón de eventos de una de las reglas.

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

Requisitos previos

Para completar este tutorial necesitará los siguientes recursos:

Paso 1: Crear una aplicación

Para configurar la aplicación de ejemplo, usará la AWS CLI y Git para crear los recursos de AWS que necesitará.

Paso 2: Ejecutar la aplicación

Ahora que ha configurado los recursos, utilizará la consola para probar las funciones.

Paso 3: Verificar los registros y el funcionamiento de la aplicación

Ahora que ha ejecutado la aplicación, utilizará la consola para comprobar los Registros de CloudWatch.

Paso 4: Eliminar los recursos

A menos que desee conservar los recursos que creó para este tutorial, puede eliminarlos ahora. Si elimina los recursos de AWS que ya no utiliza, evitará gastos innecesarios en su cuenta de AWS.