Cassandra DB

Know the component and how to use it.

Cassandra DB performs operations on an Apache Cassandra database connection.
Take a look at some of the component's configuration parameters:
Account: account to be used by the component to connect to AWS. It can be type AWSv4, with access key and secret or Basic for access to Cassandra server in a data center, with user and password. 
Operation: operation to be performed (INSERT, UPDATE, SELECT, DELETE). 
Connection String: connection string with host, port and keyspace to use.
Query: CQL specification, depending on the selected operation. This parameter accepts Double Braces. 
Max Wait For Operation (in ms): time (in ms) the application must wait until the query is finished.
Heartbeat Connection Timeout (in ms):dummy request to keep connections alive in the pool.
Fail On Error: if the option is enabled, the execution of the pipeline with error will be stopped; otherwise, the pipeline execution continues, and the result will show the value false for the "success" property.
Advanced: Opens further configuration options.
Pool Size By Actual Consumers: If "true", the number of pooled connections will be equivalent to the number of consumers configured during pipeline deployment, if "false", then the pool size is given by the pipeline deployment size, irrespective of the number of consumers.
Cassandra DB in Action
CQL (Cassandra Query Language), as the name implies, is the query language for Cassandra. It uses variables in its queries by wrapping them in Double Braces, like {{id}}. Read more in our article about Double Braces Functions. 
Operation INSERT
Input
Output
{
	"data": {},
	"insertCount": 1
}
​
Operation UPDATE
Input
Output
{
	"data": {},
	"updateCount": 1
}
Operation SELECT
Note: Databases such as Cassandra or AWS Keyspaces may automatically return paginated results if they have a significant number of registers. The Digibee Integration Platform handles this pagination automatically to consolidate the result at the output of the component as an atomic query. This means that no configuration or additional actions are required by the user to obtain these results.
Input
Output
{
	"data": [{
		"id": "5095e726-d790-4f93-9a71-10ecf2cdd72f",
		" firstName": "Rafael",
		" lastName": "Garbin"
	}],
	"rowCount": 1
}
​
Operation DELETE
Input
Output
{
	"data": {},
	"deleteCount": 1
}

Components - Previous

Structured data

DB V2

Last modified 24d ago