Triggers de base de datos: reacción a eventos CRUD

Los Atlas Database Triggers son gestores de eventos sin servidor que ejecutan automáticamente una Atlas Function cada vez que ocurre un evento CRUD específico (insertar, actualizar, reemplazar o eliminar) en una colección. Se basan en MongoDB Change Streams y eliminan la necesidad de ejecutar un proceso de sondeo o administrar infraestructura para flujos de trabajo basados en eventos.

Internamente, los Atlas triggers usan un change stream que MongoDB abre en la colección de destino. Cada evento de cambio que coincide se reenvía al trigger, que invoca la Atlas Function asociada y le proporciona el documento del evento como argumento. La función se ejecuta en el entorno de ejecución de JavaScript administrado por Atlas; no es necesario aprovisionar ni escalar servidores. Los triggers pueden gestionar hasta cientos de eventos por segundo mediante el escalado automático.

Al configurar un database trigger, debe especificar: el Cluster name y la collection que se supervisarán. Los Operation types a los que reaccionará: insert, update, replace, delete o cualquier combinación. La opción Full Document: cuando está habilitada, MongoDB obtiene el documento completo después del cambio y lo incluye en la carga útil del evento. Linked Function: la Atlas Function que se invocará.

El documento del evento que se pasa a la función del trigger contiene estos campos principales: operationType ('insert', 'update', 'replace', 'delete'), fullDocument (el documento después del cambio, si está habilitado), documentKey (el _id del documento modificado), updateDescription (en las actualizaciones: qué campos se establecieron o eliminaron) y ns (el espacio de nombres de la base de datos y la colección).

Una función trigger es una Atlas Function: JavaScript del lado del servidor que tiene acceso al objeto context (cliente de MongoDB, servicios e información del usuario) y recibe el evento de cambio como primer argumento. Este es un patrón para gestionar nuevos pedidos: enviar un correo electrónico de notificación y actualizar un contador de análisis.

Puede añadir una match expression a un trigger para que solo se active para un subconjunto de eventos. Esto se implementa como una canalización de agregación en el change stream. Por ejemplo, puede activar el trigger solo para pedidos que superen un importe determinado, solo para actualizaciones en las que haya cambiado el campo de estado o solo para reaccionar a documentos de un tenant específico.

En las operaciones INSERT y REPLACE, fullDocument siempre está disponible en el evento de cambio. En los eventos UPDATE, fullDocument solo está disponible si habilita la opción Full Document en la configuración del trigger, lo que hace que Atlas realice una búsqueda adicional del documento (una segunda lectura). Sin esta opción, solo está disponible updateDescription (los campos modificados).

Si una función trigger genera un error o supera el tiempo de espera (máximo de 90 segundos), Atlas la reintenta automáticamente hasta 3 veces con un retroceso exponencial. Si todos los reintentos fallan, el evento se registra como fallido en el registro de errores de Atlas Trigger. Debe escribir funciones trigger idempotentes: aplicar la función varias veces al mismo evento produce el mismo resultado, lo que permite gestionar los reintentos de forma segura.

Un caso de uso habitual es la sincronización de datos: cuando cambia un documento en una colección, un trigger propaga el cambio a una copia desnormalizada en otra colección. Por ejemplo, cuando cambia el correo electrónico de un usuario en la colección users, un trigger actualiza el campo de correo desnormalizado en cada documento de la colección orders que hace referencia a ese usuario.

De forma predeterminada, los Atlas triggers procesan los eventos secuencialmente, en el orden en que llegan. Si habilita event ordering off (en la configuración del trigger), varias invocaciones de funciones pueden ejecutarse en paralelo para aumentar el rendimiento, pero la función debe ser segura para la ejecución simultánea. El modo secuencial es más seguro; el modo paralelo es más rápido para colecciones con una alta tasa de eventos.

Puede activar o desactivar los triggers en cualquier momento desde la interfaz de Atlas sin eliminarlos. El Trigger Execution Log de Atlas muestra cada invocación: estado (éxito, error o tiempo de espera), duración y detalles del error. Use este registro para depurar los triggers que fallen y supervisar las tendencias de ejecución. Atlas también muestra métricas de los triggers en el panel de Atlas Monitoring.

En esta lección ha aprendido que: los Atlas Database Triggers activan una Atlas Function en eventos de inserción, actualización, reemplazo o eliminación mediante un change stream interno, las expresiones de coincidencia filtran los eventos que invocan la función y las funciones deben ser idempotentes porque Atlas reintenta automáticamente las invocaciones fallidas. A continuación, exploraremos los triggers programados y los trabajos cron.