Enviar eventos de activadores a AWS EventBridge

Create a New Error Handler

Desde la sección Configure Error Function de la página Create a Trigger, seleccione + NewFunction.

You can also select an existing Function, if one is already defined, from the dropdown.

Name the New Function

Introduce un nombre identificativo único para la función en el campo Name. Este nombre debe ser distinto de todas las demás funciones de la aplicación.

Write the Function Code

En la sección Function, escribe el código JavaScript directamente en el editor de funciones. El editor de funciones contiene una función por defecto que puedes editar según sea necesario. Para más información sobre la creación de Funciones, consulta la documentación de las Funciones.

Probar la función

En la pestaña Testing Console que se encuentra debajo del editor de la Función, puedes probar la Función introduciendo valores de ejemplo en los parámetros error y changeEvent, como se muestra en los comentarios de la consola de pruebas.

Para obtener más información sobre estos parámetros, consulte la sección Parámetros del controlador de errores en esta página.

Click Run to run the test.

Save the Function

Once you are satisfied with the custom error handler, click Save.

Autenticar a un usuario de MongoDB Atlas

Usa tu Clave API de administración de MongoDB Atlas para iniciar sesión en la CLI de App Services:

appservices login --api-key="<API KEY>" --private-api-key="<PRIVATE KEY>"

Extrae los archivos de configuración más recientes de tu aplicación

Ejecute el siguiente comando para obtener una copia local de sus archivos de configuración:

appservices pull --remote=<App ID>

Por defecto, el comando arrastra los archivos al directorio de trabajo actual. Puede especificar una ruta de directorio con el indicador opcional --local.

Write the Error Handler

Sigue los pasos en Definir una función para escribir tu código fuente del manejador de errores y tu archivo de configuración.

Consulta el siguiente controlador de errores de la plantilla como ejemplo:

exports = async function(error, changeEvent) {
   // This sample function will log additional details if the error is not
   // a DOCUMENT_TOO_LARGE error
   if (error.code === 'DOCUMENT_TOO_LARGE') {
      console.log('Document too large error');
      // Comment out the line below in order to skip this event and not suspend the Trigger
      throw new Error('Encountered error: ${error.code}');
   }
   console.log('Error sending event to EventBridge');
   console.log('DB: ${changeEvent.ns.db}');
   console.log('Collection: ${changeEvent.ns.coll}');
   console.log('Operation type: ${changeEvent.operationType}');
   // Throw an error in your Function to suspend the Trigger
   // and stop processing additional events
   throw new Error('Encountered error: ${error.message}');
};

Para más información sobre la creación de funciones, consulta Funciones.

Agregar el manejador de errores a tu configuración de activador

Agrega un atributo error_handler al archivo de configuración de activador en la carpeta Triggers.

El archivo de configuración del activador debe parecerse al siguiente:

      {
         "name": "...",
         "type": "DATABASE",
         "event_processors": {
            "AWS_EVENTBRIDGE": {
               "config": {
                  "account_id": "<AWS Account ID>",
                  "region": "<AWS Region>",
                  "extended_json_enabled": <boolean>
               }
            }
         },
         "error_handler": {
            "config": {
               "enabled": <boolean>,
               "function_name": "<Error Handler Function Name>"
            }
         }
      }

Para obtener más información, consulte Archivos de configuración de activadores.

Implementa tus cambios

Ejecute el siguiente comando para implementar sus cambios:

appservices push

Autenticar a un usuario de MongoDB Atlas

Llama al endpoint de Inicio de sesión con tu par de claves API de Administración de MongoDB Atlas:

curl -X POST \
  https://services.cloud.mongodb.com/api/admin/v3.0/auth/providers/mongodb-cloud/login \
  -H 'Content-Type: application/json' \
  -H 'Accept: application/json' \
  -d '{
    "username": "<Public API Key>",
    "apiKey": "<Private API Key>"
  }'

If authentication succeeds, the response body contains a JSON object with an access_token value:

{
  "access_token": "<access_token>",
  "refresh_token": "<refresh_token>",
  "user_id": "<user_id>",
  "device_id": "<device_id>"
}

El access_token otorga acceso a la API de administración de App Services. Debes incluirlo como un token Bearer en el encabezado Authorization para todas las solicitudes de la App Services Admin API.

Create a Deployment Draft (Optional)

A draft represents a group of application changes that you can deploy or discard as a single unit. If you don't create a draft, updates automatically deploy individually.

To create a draft, send a POST request with no body to the Create a Deployment Draft endpoint:

curl -X POST 'https://services.cloud.mongodb.com/api/admin/v3.0/groups/{groupId}/apps/{appId}/drafts' \
-H 'Content-Type: application/json' \
-H 'Authorization: Bearer <access_token>'

Crear la función de gestión de errores

Cree la función para gestionar errores ante la falla de un activador de AWS EventBridge a través de una solicitud POST al Crear una nueva Función endpoint.

curl -X POST \
   https://services.cloud.mongodb.com/api/admin/v3.0/groups/{groupId}/apps/{appId}/functions \
   -H 'Authorization: Bearer <access_token>' \
   -d '{
         "name": "string",
         "private": true,
         "source": "string",
         "run_as_system": true
      }'

Create the AWS EventBridge Trigger

Create the AWS EventBridge Trigger with error handling enabled via a POST request to the Create a Trigger endpoint.

curl -X POST \
   https://services.cloud.mongodb.com/api/admin/v3.0/groups/{groupId}/apps/{appId}/triggers \
   -H 'Authorization: Bearer <access_token>' \
   -d '{
         "name": "string",
         "type": "DATABASE",
         "config": {
            "service_id": "string",
            "database": "string",
            "collection": "string",
            "operation_types": {
               "string"
            },
            "match": ,
            "full_document": false,
            "full_document_before_change": false,
            "unordered": true
         },
         "event_processors": {
            "AWS_EVENTBRIDGE": {
               "account_id": "string",
               "region": "string",
               "extended_json_enabled": false
            },
         },
         "error_handler": {
            "enabled": true,
            "function_id": "string"
         }
      }'

Implementa tus cambios

Si has creado un borrador, puedes implementar todos los cambios en el borrador enviando una POST solicitud sin cuerpo al punto final Implementar un borrador de implementación.

Si no creaste un borrador como primer paso, las solicitudes individuales de función y activador se implementan automáticamente.

curl -X POST \
'https://services.cloud.mongodb.com/api/admin/v3.0/groups/{groupId}/apps/{appId}/drafts/{draftId}/deployment' \
--header 'Content-Type: application/json' \
--header 'Authorization: Bearer <access_token>' \