Cassandra DB

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

O Cassandra DB realiza operações em uma conexão de database Apache Cassandra.

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âmetroDescriçãoValor padrãoTipo de dado

Account

Conta a ser utilizada pelo componente para conectar na AWS. Pode ser do tipo AWSv4, com access key e secret ou Basic para acesso a servidor do cassandra em uma data center, com usuário e senha.

N/A

String

Operation

Operação a ser executada (Insert, Update, Select, Delete).

N/A

String

Connection String

String de conexão com host, porta e keyspace a ser utilizado.

cassandra://localhost:9142/keyspace

String

Query (DB)

Especificação CQL, conforme a operação selecionada. Este parâmetro aceita Double Braces.

SELECT * FROM EXAMPLE

String

Max Wait For Operation (in ms)

Tempo (em ms) em que a aplicação deve aguardar até a query ser finalizada.

60000

Inteiro

Heartbeat Connection Timeout (in ms)

Dummy request para manter conexões vivas no pool.

60000

Inteiro

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, e o resultado mostrará o valor false para a propriedade "success".

False

Booleano

Advanced

Abre para posteriores opções de configuração.

False

Booleano

Pool Size By Actual Consumers

Se "verdadeiro", o número de conexões agrupadas será equivalente ao número de consumidores configurados durante a implantação do pipeline; se "falso", então o tamanho do pool é dado pelo tamanho da implantação do pipeline, independentemente do número de consumidores.

False

Booleano

Cassandra DB em Ação

O CQL (Cassandra Query Language), como já diz o nome, é a linguagem de consulta para o Cassandra, ele usa variáveis em suas consultas envolvendo-as em Double Braces, como {{id}}. Leia mais no nosso artigo sobre Funções Double Braces.

Operação Insert

Entrada

  • Account: cassandra-acc

  • Operation: Insert

  • Connection String: {{global.cassandra-url}}

  • Query: INSERT INTO CUSTOMER (id, first_name) VALUES ({{ message.id }}, {{ message.name }});

  • Fail On Error: false

Saída

{ "data": {},
 "insertCount": 1 
}

Operação Update

Entrada

  • Account: cassandra-acc

  • Operation: Update

  • Connection String: {{global.cassandra-url}}

  • Query: UPDATE CUSTOMER SET first_name = {{ message.newName }} WHERE id = {{ message.id }};

  • Fail On Error: false

Saída

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

Operação Select

Os bancos de dados Cassandra ou Keyspaces da AWS podem retornar automaticamente os resultados de forma paginada caso possuam um número considerável de registros. A Digibee Integration Platform trata essa paginação de forma automática, para que o resultado seja consolidado na mensagem de saída do componente como uma consulta atômica. Isso elimina a necessidade de qualquer configuração ou ações adicionais por parte do usuário para obter esses resultados.

Entrada

  • Account: cassandra-acc

  • Operation: Select

  • Connection String: {{global.cassandra-url}}

  • Query: SELECT * FROM CUSTOMER WHERE id = {{ message.if }};

  • Fail On Error: false

Saída

{
	"data": [{
		"id": "5095e726-d790-4f93-9a71-10ecf2cdd72f",
		" firstName": "Rafael",
		" lastName": "Garbin"
	}],
	"rowCount": 1
}

Operação Delete

Entrada

  • Account: cassandra-acc

  • Operation: Delete

  • Connection String: {{global.cassandra-url}}

  • Query: DELETE FROM CUSTOMER WHERE id = {{ message.if }};

  • Fail On Error: false

Saída

{
	"data": {},
	"deleteCount": 1
}

Last updated