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

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

Write the Function Code

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.

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, consulta la sección Parámetros del Gestor 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

Utilice su 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>"

Extraiga los últimos archivos de configuración de su aplicación

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

appservices pull --remote=<App ID>

De forma predeterminada, el comando extrae 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.

Agregue el controlador de errores a la configuración de su disparador

Agregue un atributo error_handler a su archivo de configuración de disparador 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.

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

Implementar sus cambios

Si creó un borrador, puede 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>' \