MongoDB

Permite a configuração de uma collection do MongoDB que receberá as mensagens trafegadas.

Parâmetros

Parâmetros aceitos para esse tipo de sindicância de destino:

Campo	Descrição	Valor
mongodb.collection	Nome da collection	Tipo: string Obrigatório
mongodb.database	Nome do database	Tipo: string Obrigatório
mongodb.uri	Connection string	Tipo: string Obrigatório
mongodb.operation	Operação	Tipo: enum[insert-one update-one] Obrigatório
mongodb.update_one	Parâmetros da operação update-one	Tipo: object Obrigatório se operation for update-one
mongodb.update_one.filter	Campos que serão usados como chave do filtro. A chave representa o caminho do campo no documento e o valor é o caminho do campo do valor presente no Firehose	Tipo: map[string]string Obrigatório
mongodb.update_one.upsert	Define se upsert estará ativo	Tipo: boolean Opcional Valor padrão: false

Caso algum campo da URI tenha caracteres especiais, será necessário converter os caracteres utilizando percent encoding.Documentação

Requisição

curl --location '<HOST>/v1/configs' \
--header 'Content-Type: application/json' \
--header 'Authorization: <ACCESS-TOKEN>' \
--data '{
    "output": {
        "type": "MONGODB",
        "mongodb": {
           "collection": "",
           "database": "",
           "uri": "",
           "operation": "update-one",
           "update_one": {
               "filter": {
                  "document.field.example": "firehose.field.name"
               },
              "upsert": false
           }
        }
    }
}'

Resposta

A resposta desse endpoint será no seguinte formato:

{
  "id": "FIREHOSE-ID",
  "output": {
    "type": "MONGODB",
    "mongodb": {
       "collection": "*",
       "database": "*",
       "uri": "*",
       "operation": "update-one",
       "update_one": {
          "filter": {
            "document.field.example": "firehose.field.name"
          },
          "upsert": true
       }
    }
  }
}