Enviar eventos de activadores a AWS EventBridge

Crear un nuevo controlador de errores

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

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 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.

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.

Autenticar 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.

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.

Vea el siguiente controlador de errores de 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 disparador 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 un usuario de MongoDB Atlas

Llame al punto final de inicio de sesión con su par de claves de 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>"
  }'

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. Debes incluirlo como un token Bearer en el encabezado Authorization para todas las solicitudes de la App Services Admin API.

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 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 creó un borrador como primer paso, las solicitudes de función y disparador individuales 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>' \