Enviar eventos de activadores a AWS EventBridge

Crear un nuevo controlador de errores

En la sección Configure Error Function, seleccione + New Function.

También puede seleccionar una función existente, si ya hay una definida, desde el menú desplegable.

Nombrar la nueva función

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

Escribe el código de función

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

Pruebe la función

En la pestaña Testing Console debajo del editor de funciones, puede probar la función pasando valores de ejemplo a 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.

Haga clic en Run para ejecutar la prueba.

Guardar la función

Una vez que esté satisfecho con el controlador de errores personalizado, haga clic en Save.

Escriba el controlador de errores

Siga los pasos de Definir una función para escribir el código fuente y el archivo de configuración de su controlador de errores.

Para obtener el código fuente del controlador de errores, consulte el siguiente controlador de errores de plantilla:

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

Agregue un controlador de errores a su configuración de disparador

Agregue un atributo error_handler al archivo de configuración del disparador en la carpeta Triggers. El archivo de configuración del disparador debería ser similar 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 sobre los archivos de configuración de activadores, consulte Archivos de configuración de activadores.

Autenticar un usuario de MongoDB Atlas

Llame al punto final de autenticación del usuario administrador con su par de claves API 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>"
  }'

Si la autenticación es exitosa, el cuerpo de la respuesta contiene un objeto JSON con un valor access_token:

{
  "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. Debe incluirlo como token de portador en el encabezado Authorization para todas las solicitudes de la API de administración.

Crear un borrador de implementación (opcional)

Un borrador representa un grupo de cambios en la aplicación que se pueden implementar o descartar como una sola unidad. Si no se crea un borrador, las actualizaciones se implementan automáticamente de forma individual.

Para crear un borrador, envíe una POST solicitud sin cuerpo al punto final Crear un borrador de implementación:

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 manejar errores de un disparador de AWS EventBridge fallido a través de una POST solicitud al punto final Crear una nueva función.

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

Crear el disparador de AWS EventBridge

Cree el disparador de AWS EventBridge con el manejo de errores habilitado a través de una POST solicitud al punto final Crear un disparador.

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"
         }
      }'

Implementar el borrador

Si creó un borrador, puede implementar todos los cambios enviando una POST solicitud sin cuerpo al punto final "Implementar un borrador de implementación". Si no creó un borrador como primer paso, las solicitudes individuales de funciones y activadores se implementaron 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>' \