Tutorial: Chamar uma API de terceiros a partir de um trigger

Navegue até a página Valores.

No Atlas, acesse a página Triggers.

1. Se ainda não tiver sido exibido, selecione a organização que contém seu projeto no menu Organizations na barra de navegação.

2. Se ainda não estiver exibido, selecione seu projeto no menu Projects na barra de navegação.

3. Na barra lateral, clique em Triggers sob o título Streaming Data.

A página Acionadores é exibida.

1. Clique no botão View All Apps.

2. Clique na aplicação em que você deseja criar o Trigger.

3. Na barra lateral, clique em Values sob o título Build.

Armazene o ID da chave de acesso.

1. Clique em Create a Value.

2. Insira AwsAccessKeyId como Value Name.

3. Selecione o tipo Value.

4. Selecione a opção Custom Content e insira seu ID de chave de acesso AWS.

   Observação

   Você deve inserir o ID da chave de acesso como um valor de string com aspas ("<accessKeyId>").

5. Clique em Save Draft.

Armazene a chave de acesso secreta.

1. Clique em Create a Value.

2. Insira AwsSecretAccessKey como Value Name.

3. Selecione o tipo Value.

4. Selecione a opção Link to Secret.

5. Insira AwsSecretAccessKeySecret e clique em Create "AwsSecretAccessKeySecret" para nomear o segredo.

   Cole sua chave de acesso secreto AWS no campo que aparece abaixo do nome secreto.

6. Clique em Save Draft para criar o segredo e o valor.

Navegue até a página Triggers.

No Atlas, acesse a página Triggers.

1. Se ainda não tiver sido exibido, selecione a organização que contém seu projeto no menu Organizations na barra de navegação.

2. Se ainda não estiver exibido, selecione seu projeto no menu Projects na barra de navegação.

3. Na barra lateral, clique em Triggers sob o título Streaming Data.

A página Acionadores é exibida.

Crie o gatilho.

1. Clique em Add Trigger para abrir a página de configuração do trigger.

2. Selecione o tipo de trigger Database e, em seguida, configure o trigger usando os seguintes valores:

   Contexto	Valor
   Trigger Name	WriteDocumentToS3Trigger
   Watch Against	Collection
   Cluster Name	Nome do cluster de teste
   Database Name	Nome do seu banco de dados de teste
   Collection Name	Nome da sua collection de teste
   Operation Type	Selecione apenas Insert.
   Event Type	Function

3. Na seção Function, selecione + New Function.

Adicione a dependência aws-sdk.

1. Na seção Function, clique em Add Dependency.

2. Na janela Add Dependency, insira aws-sdk como Define a Package Name e deixe Package Version em branco para usar a versão mais recente.

3. Clique em Add para adicionar o pacote.

Insira o seguinte código para definir a função.

Substitua YOUR_AWS_REGION e YOUR_S3_BUCKET_NAME pela sua região da AWS e pelo nome completo do bucket do Console de gerenciamento da AWS.

1
/*
2
 * Write a newly-inserted document to an S3 bucket as an Extended JSON object.
3
 */
4
exports = async function writeDocumentToS3(changeEvent) {
5
  const { fullDocument } = changeEvent;
6
7
  // require calls must be in the exports function
8
  const S3 = require("aws-sdk/clients/s3");
9
  const s3 = new S3({
10
    accessKeyId: context.values.get("AwsAccessKeyId"),
11
    secretAccessKey: context.values.get("AwsSecretAccessKey"),
12
    region: "YOUR_AWS_REGION",
13
  });
14
15
  const key = `inserted-documents/${fullDocument._id.toString()}.json`;
16
17
  // https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/S3.html#putObject-property
18
  await s3.putObject({
19
    Bucket: "YOUR_S3_BUCKET_NAME",
20
    Key: key,
21
    Body: EJSON.stringify(fullDocument),
22
    ContentType: "application/json",
23
  }).promise();
24
25
  return `Wrote document ${fullDocument._id} to ${key}`;
26
};

Cada vez que um documento é inserido, a função faz o seguinte:

• Lê o documento inserido do campofullDocument do evento de alteração.

• Cria um cliente S3 que se autentica com as credenciais da AWS armazenadas em seus Valores.

• Grava o documento no prefixo inserted-documents/ do seu bucket como <_id>.json.

Clique em Save para criar o Trigger.

Conecte-se ao seu cluster com mongosh.

Para saber como, consulte Conectar-se a um cluster via mongosh.

Insira um documento na coleção que o Trigger observa.

O exemplo a seguir insere um documento na collection de teste. Substitua YOUR_DATABASE_NAME e YOUR_COLLECTION_NAME pelo banco de dados e pela coleção que você inseriu quando criou o Trigger.

// Replace YOUR_DATABASE_NAME and YOUR_COLLECTION_NAME with the
// database and collection that the Trigger watches.
use YOUR_DATABASE_NAME
db.YOUR_COLLECTION_NAME.insertOne({
  tutorialTest: "atlas-trigger-s3",
  createdAt: new Date()
})

{
  acknowledged: true,
  insertedId: ObjectId('6accda8d1bed071fd18dc505')
}

Observe o valor insertedId da sua saída. A função usa esse valor como nome do objeto S3 .

Confirme que o objeto existe no seu bucket S3.

No Console de gerenciamento da AWS, abra seu bucket S3 e navegue até o prefixo inserted-documents/. Um objeto chamado <insertedId>.json é exibido, onde <insertedId> é o valor insertedId da etapa anterior.