Mongo DB

Descubra mais sobre o componente Mongo DB e saiba como utilizá-lo na Digibee Integration Platform.

O Mongo DB realiza operações em uma conexão de database Mongo, retornando apenas um objeto JSON.

Importante: cuidado com o consumo de memória para datasets grandes.

Parâmetros

Dê uma olhada nas opções de configuração do componente. Parâmetros suportados por expressões Double Braces estão marcados com (DB).

Parâmetro

Descrição

Valor padrão

Tipo de dado

Account

Conta a ser utilizada pelo componente. Contas suportadas: Basic e Certificate Chain.

N/A

String

Use SSL/TLS to connect

Quando ativada, uma conexão com criptografia SSL/TLS será utilizada.

False

Booleano

Custom SSL/TLS certificate

Define o certificado customizado que pode ser usado para a conexão com SSL/TLS. Este campo suporta expressões Double Braces (DB).

N/A

String

Allow invalid hostnames

Quando ativada, a opção ignora a validação de hostnames em certificados SSL/TLS.

False

Booleano

Operation

Operação a ser executada (Find, Aggregate, Delete One, Delete Many, Insert One, Insert Many, Update One, Update Many, Replace One, List Indexes, Create Index e Drop Index).

Find

String

Connection String

Conexão de string.

mongodb://localhost:27017

String

Database Name

Nome da base de dados.

databaseName

String

Collection Name

Nome da coleção.

collectionName

String

Expire after seconds

Tempo (em segundos) para expiração de documentos que utilizem um índice TTL. Disponível apenas se a operação Create Index for selecionada.

Inteiro

Query (DB)

Especificação Mongo a ser enfileirada. Por exemplo: { _id: ObjectId( {{ message.$.id }} ) }

N/A

String

Document

Disponível somente se Insert One, Insert Many, Update One, Update Many ou Replace One estiverem selecionadas.

N/A

String

Limit (DB)

Especificação do número máximo de objetos que podem ser retornados.

Inteiro

Skip (DB)

Número de objetos a serem pulados antes de retornar para a query.

Inteiro

Sort

Especificação do parâmetro a ser ordenado pelo campo.

N/A

String

Fail On Error

Se a opção estiver habilitada, a execução do pipeline com erro será interrompida; do contrário, a execução do pipeline continua, mas o resultado vai mostrar um valor falso para a propriedade "success".

False

Booleano

Max Wait For Connection (in ms)

Apresenta padrão 10000 (você pode escolher a opção).

10000

Inteiro

Connection Timeout (in ms)

Apresenta 30000 (você pode escolher a opção).

30000

Inteiro

Socket Timeout (in ms)

300000 ou outro valor.

300000

Inteiro

Heartbeat Connection Timeout (in ms)

10000 (você pode escolher a opção).

10000

Inteiro

Max Connection Idle Timeout (in ms)

Apresenta padrão 1800000.

1800000

Inteiro

Importante: atualmente o componente suporta apenas contas Basic e Certificate Chain e deve ser informado através do campo Account, não diretamente na string de conexão.

Você pode:

utilizar um JSON fixo:

document = "{\"data\": [{\"object\": 1}, {\"object\": 2}]}"

conseguir algum JSON da mensagem, que vai buscar o objeto 'data' da mensagem:

document = "{{ message.$.data }}

combinar ambos os exemplos:

document = "{\"data\": [{\"object\": {{ message.$.id1 }}}, {\"object\": {{ message.$.id2 }}}]}"]

Se o Mongo DB precisar de alguma autenticação, você deverá criar uma conta (tipo BASIC) e utilizá-la no componente.

Para converter Double Braces, nós utilizamos especificações de JSON Path. Leia a documentação sobre JSON Path no GitHub.

Mongo DB em Ação

Operação Find

Config

{
	"operation": "FIND",
	"databaseName": "test",
	"collectionName": "model",
	"url": "mongodb://localhost:27017",
	"query": "{_id: ObjectId({{ message.$.parameters.id }})}",
	"failOnError": false
}

Entrada

{
	"parameters": {
		"id": "5c87c7af06c3af7dbedc7bb3"
	}
}

Saída

{"data": [...some data...],"rowCount": 10,"updateCount": 0}

Operação Replace One

Config

{
	"data": [...some data...],
	"rowCount": 10,
	"updateCount": 0
}

Entrada

{
	"operation": "REPLACE_ONE",
	"databaseName": "test",
	"collectionName": "model",
	"document": "{\"data\": [{\"object\": 1}, {\"object\": 2}]}",
	"url": "mongodb://localhost:27017",
	"query": "{_id: ObjectId({{ message.$.parameters.id }})}",
	"failOnError": false
}

Saída

{
    "data": {},
    "rowCount": 0,
    "updateCount": 1
}

Operação Update

Config

{
	"operation": "UPDATE",
	"databaseName": "test",
	"collectionName": "model",
	"document": "{\"$set\": {\"data\": [{\"object\": 1}, {\"object\": 2}]}}",
	"url": "mongodb://localhost:27017",
	"query": "{_id: ObjectId({{ message.$.parameters.id }})}",
	"failOnError": false
}

Entrada

{
	"parameters": {
		"id": "5c87c7af06c3af7dbedc7bb3"
	}
}

Saída

{
	"data": {},
	"rowCount": 0,
	"updateCount": 1
}

Operação Update Many

Config

{
	"operation": "UPDATE_MANY",
	"databaseName": "test",
	"collectionName": "model",
	"document": "{\"$set\": {\"data\": [{\"object\": 1}, {\"object\": 2}]}}",
	"url": "mongodb://localhost:27017",
	"query": "{name: ObjectId({{ message.$.parameters.name }})}",
	"failOnError": false
}

Entrada

{
	"parameters": {
		"name": "NAME"
	}
}

Saída

{{
	"data": {},
	"rowCount": 0,
	"updateCount": 1
}

Operação Delete

Config

{
	"operation": "DELETE",
	"databaseName": "test",
	"collectionName": "model",
	"url": "mongodb://localhost:27017",
	"query": "{_id: ObjectId({{ message.$.parameters.id }})}",
	"failOnError": false
}

Entrada

{
	"parameters": {
		"id": "5c87c7af06c3af7dbedc7bb3"
	}
}

Saída

{
	"data": {},
	"rowCount": 10,
	"updateCount": 0
}

Operação Delete Many

Config

{
	"operation": "DELETE_MANY",
	"databaseName": "test",
	"collectionName": "model",
	"url": "mongodb://localhost:27017",
	"query": "{name: {{ message.$.data.name }}}",
	"failOnError": false
}

Entrada

{
	"data": {
		"name": "NAME"
	}
}

Saída

{
	"data": {},
	"rowCount": 10,
	"updateCount": 0
}

Operação Insert

Config

{
	"operation": "INSERT",
	"databaseName": "test",
	"collectionName": "model",
	"document": "{\"data\": {{ message.$.body }}}",
	"url": "mongodb://localhost:27017",
	"failOnError": false
}

Entrada

{
	"parameters": {
		"id": "5c87c7af06c3af7dbedc7bb3"
	},
	"body": [
		{"a": 1},
		{"a": 2}
	]
}

Saída

{
	"data": {},
	"rowCount": 0,
	"updateCount": 1
}

Operação Insert Many

Config

{
	"operation": "INSERT_MANY",
	"databaseName": "test",
	"collectionName": "model",
	"document": "{{ message.$.body }}",
	"url": "mongodb://localhost:27017",
	"failOnError": false
}

Entrada

{
	"parameters": {
		"id": "5c87c7af06c3af7dbedc7bb3"
	},
	"body": [
		{"a": 1},
		{"a": 2}
	]
}

Saída

{
	"data": {},
	"rowCount": 0,
	"updateCount": 1
}

Operação Aggregate

Config

{
	"operation": "AGGREGATE",
	"databaseName": "test",
	"collectionName": "model",
	"url": "mongodb://localhost:27017",
	"query": "[{\"$match\":{\"zip\":\"90210\"}},{\"$group\":{\"_id\":null,\"count\":{\"$sum\":1}}}]",
	"failOnError": false
}

Entrada

{
	"parameters": {
		"id": "5c87c7af06c3af7dbedc7bb3"
	}
}

Saída

{
	"data": [...some data...],
	"rowCount": 10,
	"updateCount": 0
}

Operação List Indexes

Config

{
	"operation": "LIST_INDEXES",
	"databaseName": "test",
	"collectionName": "model",
	"url": "mongodb://localhost:27017",
	"failOnError": false
}

Entrada

{ }

Saída

{
	"data": [...some data...],
	"rowCount": 10
}

Operação Create Index

Config

{
	"operation": "CREATE_INDEX",
	"databaseName": "test",
	"collectionName": "model",
	"url": "mongodb://localhost:27017",
	"expireAfterSeconds": "3600",
	"query": "{ \"createdAt\": 1 }",
	"failOnError": false
}

Entrada

{ }

Saída

{
	"data": "createdAt_1",
	"updateCount": 1
}

Operação Drop Index

Config

{
	"operation": "DROP_INDEX",
	"databaseName": "test",
	"collectionName": "model",
	"url": "mongodb://localhost:27017",
	"query": "{ \"createdAt\": 1 }",
	"failOnError": false
}

Entrada

{ }

Saída

{
	"data": { },
	"updateCount": 1
}

O Mongo DB suporta Double Braces estáticos nos seguintes parâmetros previamente especificados:

operation
url

AnteriorInfluxDB PróximoObject Store

Atualizado há 1 ano