Enviar eventos de gatilho para o AWS EventBridge

Crie um novo manipulador de erros

Na seção Configure Error Function da página Create a Trigger , selecione + NewFunction.

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 aplicação.

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.

Autenticar um usuário do MongoDB Atlas

Use sua chave de API de administração do MongoDB Atlas para fazer login na App Services CLI:

appservices login --api-key="<API KEY>" --private-api-key="<PRIVATE KEY>"

Extraia os arquivos de configuração mais recentes do seu aplicativo

Execute o seguinte comando para obter uma cópia local dos seus arquivos de configuração:

appservices pull --remote=<App ID>

Por padrão, o comando extrai arquivos para o diretório de trabalho atual. Você pode especificar um caminho de diretório com a bandeira --local opcional.

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.

Consulte o seguinte manipulador de erros de modelo como exemplo:

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 mais informações sobre como criar funções, consulte Funções.

Adicione o 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, consulte Arquivos de configuração do trigger.

Implemente suas alterações

Execute o seguinte comando para implementar suas alterações:

appservices push

Autenticar um usuário do MongoDB Atlas

Ligue para o endpoint de login com seu par de chaves da API de administração 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 da App Services Admin API .

(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 de AWS Eventbridge trigger um com falha por meio de uma POST solicitação de 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
      }'

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

Implemente suas alterações

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 trigger são implementadas 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>' \