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 e o arquivo de configuração do manipulador de erros.

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

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

Adicionar um manipulador de erros à sua configuração de trigger

Adicione um atributo error_handler ao seu arquivo de configuração de trigger na pasta Triggers . O arquivo de configuração do trigger deve ser semelhante 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 do trigger, consulte Arquivos de configuração do 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 de portador no cabeçalho Authorization para todas as solicitações da App Services Admin API.

Criar um esquema de implantação (opcional)

Um rascunho representa um grupo de alterações para aplicativos 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 Criar um rascunho de sistema:

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

Criar a função de manipulador de erros

Crie a função para lidar com erros de um trigger do AWS EventBridge com falha por meio de uma solicitação POST para o endpoint 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
      }'

Criar o AWS EventBridge Trigger

Crie o AWS EventBridge Trigger com o tratamento de erros habilitado por meio de uma solicitação POST para o endpoint 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 de POST sem corpo para o endpoint Implantar um rascunho de implantação . Se você não criou um rascunho como uma primeira etapa, a função individual e as solicitações de gatilho são 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>' \