Enviar eventos de gatilho para o AWS EventBridge

Crie um novo manipulador de erros

Na seção Configure Error Function, selecione + New Function.

Você também pode selecionar uma função existente, se já estiver definida, no menu suspenso.

Nomear a nova função

Insira um nome de identificação exclusivo para a função no campo Name. Esse nome deve ser distinto de todas as outras funções do aplicativo.

Escrever o código da função

Na seção Function, escreva o código JavaScript diretamente no editor de funções. O editor de funções contém uma função padrão que você pode editar conforme o necessário. Para obter mais informações sobre a criação de funções, consulte a documentação Funções.

Testar a função

Na aba Testing Console abaixo do editor de funções, você pode testar a função passando valores de exemplo para os parâmetros error e changeEvent , conforme mostrado nos comentários do console de teste.

Para obter mais informações sobre esses parâmetros, consulte a seção Parâmetros do manipulador de erros nesta página.

Clique em Run para executar o teste.

Salvar a função

Quando estiver satisfeito com o manipulador de erros personalizado, clique em Save.

Grave o manipulador de erros

Siga as etapas em Definir uma função para escrever o código-fonte do manipulador de erros e o arquivo de configuração.

Para obter o código-fonte do manipulador de erros, consulte o seguinte modelo de manipulador de erros:

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

Adicione um manipulador de erro à configuração do Trigger

Adicione um atributo error_handler ao seu arquivo de configuração do trigger na pasta Triggers. O arquivo de configuração do trigger deve se assemelhar ao seguinte:

      {
         "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 obter mais informações sobre arquivos de configuração de trigger, consulte Arquivos de configuração de trigger

Autenticar um usuário do MongoDB Atlas

Chame o endpoint de autenticação do usuário administrador com seu par de chaves da API do 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>"
  }'

Se a autenticação for bem-sucedida, o corpo da resposta conterá um objeto JSON com um valor access_token :

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

O access_token concede acesso à App Services Admin API. Você deve incluí-lo como um token do portador no cabeçalho Authorization para todas as solicitações de API Admin.

(Opcional) Criar um esquema de implantação

Um rascunho representa um grupo de alterações para aplicação que você pode distribuir ou descartar como uma única unidade. Se você não criar um rascunho, as atualizações serão implementadas automaticamente de forma individual.

Para criar um rascunho, envie uma solicitação POST sem corpo para o endpoint Create a Deployment Draft (criar um rascunho de implantação):

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

Crie a função do manipulador de erros

Crie a função para lidar com erros para um trigger do AWS EventBridge com falha por meio de uma solicitação POST para o endpoint Create a new Function (Criar uma nova função).

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

Crie o trigger do AWS EventBridge

Crie o trigger do AWS EventBridge com o tratamento de erros habilitado por meio de uma solicitação POST para o endpoint Create a Trigger (criar um trigger).

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

Implantar o esquema

Se você criou um rascunho, poderá implantar todas as alterações no rascunho enviando uma solicitação POST sem corpo para o endpoint Implantar um rascunho de implantação . Se você não criou um rascunho como primeira etapa, a função individual e as solicitações de trigger foram implantadas automaticamente.

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