Para implementar y suscribir la canalización de reproducción de eventos

En este tutorial, se muestra cómo implementar la canalización de reproducción de eventos y suscribirla a un tema de Amazon SNS. Con este proceso, se convierte de forma automática la plantilla de AWS SAM asociada con la canalización en una pila de AWS CloudFormation y, a continuación, se implementa la pila en su Cuenta de AWS. Con este proceso, también se crea y configura el conjunto de recursos que componen la canalización de reproducción de eventos, incluida una cola de Amazon SQS y una función Lambda.

Para obtener más información sobre el filtrado de eventos, consulte Políticas de filtro de suscripciones de Amazon SNS en esta guía.

1. Inicie sesión en la consola de AWS Lambda.

2. En el panel de navegación, elija Functions (Funciones) y, a continuación, Create function (Crear función).

3. En la página Create function (Crear función), proceda del modo siguiente:

   1. Elija Examinar el repositorio de aplicaciones sin servidor, Aplicaciones públicas, Mostrar aplicaciones que crean roles de IAM personalizados o políticas de recursos.

   2. Busque fork-event-replay-pipeline y, a continuación, elija la aplicación.

4. En la página fork-event-replay-pipeline, haga lo siguiente:

   1. En la sección Application settings (Configuración de la aplicación), escriba el valor de Application name (Nombre de aplicación) (por ejemplo, my-app-replay).

      nota

      Para cada implementación, el nombre de la aplicación debe ser único. Si reutiliza un nombre de aplicación, la implementación actualizará solo la pila de AWS CloudFormation implementada anteriormente (en lugar de crear una nueva).

   2. (Opcional) Introduzca una de las siguientes LogLevelconfiguraciones para la ejecución de la función Lambda de la aplicación:

      • DEBUG

      • ERROR

      • INFO (predeterminado)

      • WARNING

   3. (Opcional) Para ReplayQueueRetentionPeriodInSeconds, introduzca el tiempo, en segundos, durante el que la cola de reproducción de Amazon SQS guarda el mensaje. Si no escribe un valor, se usan 1 209 600 segundos (14 días).

   4. Para TopicArn, introduzca el ARN del tema de Amazon SNS al que se va a suscribir esta instancia de la canalización de bifurcación.

   5. Para DestinationQueueName, introduzca el nombre de la cola de Amazon SQS a la que la función de reproducción de Lambda reenvía los mensajes.

   6. (Opcional) Para SubscriptionFilterPolicy, introduzca la política de filtrado de suscripciones de Amazon SNS, en formato JSON, que se utilizará para filtrar los eventos entrantes. La política de filtro decide qué eventos se almacenan en búfer para la reproducción. Si no escribe ningún valor, no se utiliza el filtrado (todos los eventos se almacenan en búfer para la reproducción).

   7. Elija I acknowledge that this app creates custom IAM roles, resource policies and deploys nested applications (Confirmo que esta aplicación crea políticas de recursos o roles de IAM personalizados e implementa aplicaciones anidadas) y, a continuación, elija Deploy (Implementar).

En la my-app-replaypágina Estado de despliegue de, Lambda muestra el estado Su aplicación se está desplegando.

En la sección Resources (Recursos), AWS CloudFormation comienza a crear la pila y muestra el estado CREATE_IN_PROGRESS para cada recurso. Cuando el proceso se haya completado, AWS CloudFormation mostrará el estado CREATE_COMPLETE.

Cuando se haya completado la implementación, Lambda muestra el estado La aplicación se ha implementado.

Los mensajes publicados en su tema de Amazon SNS se almacenan en búfer para reproducirlos en la cola de Amazon SQS aprovisionada de manera automática por la canalización de reproducción de eventos.

nota

De forma predeterminada, la reproducción está deshabilitada. Para habilitar la reproducción, vaya a la página de la función en la consola de Lambda, expanda la sección Diseñador, seleccione el mosaico SQS y, a continuación, en la sección SQS, elija Habilitado.