Cassandra DB
Discover more about the Cassandra DB component and how to use it on the Digibee Integration Platform.
Last updated
Discover more about the Cassandra DB component and how to use it on the Digibee Integration Platform.
Last updated
Cassandra DB performs operations on an Apache Cassandra database connection.
Take a look at the configuration parameters of the component. Parameters supported by Double Braces expressions are marked with (DB)
.
Parameter | Description | Default value | Data type |
---|---|---|---|
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.
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
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
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.
Account: cassandra-acc
Operation: Select
Connection String: {{global.cassandra-url}}
Query: SELECT * FROM CUSTOMER WHERE id = {{ message.if }};
Fail On Error: false
Account: cassandra-acc
Operation: Delete
Connection String: {{global.cassandra-url}}
Query: DELETE FROM CUSTOMER WHERE id = {{ message.if }};
Fail On Error: false
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.
N/A
String
Operation
Operation to be performed (Insert, Update, Select, Delete).
N/A
String
Connection String
Connection string with host, port, and keyspace to use.
cassandra://localhost:9142/keyspace
String
Query (DB)
CQL specification, depending on the selected operation. This parameter accepts Double Braces.
SELECT * FROM EXAMPLE
String
Max Wait For Operation (in ms)
Time (in ms) the application must wait until the query is finished.
60000
Integer
Heartbeat Connection Timeout (in ms)
Dummy request to keep connections alive in the pool.
60000
Integer
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.
False
Boolean
Advanced
Opens further configuration options.
False
Boolean
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.
False
Boolean