Apache Cassandra / ScyllaDB

Wide-column database: run CQL statements and batches, manage keyspaces, and read and write rows

Signs in with: Connection details
Runs on: Cloud or On-Prem Worker
Operations: 26
Ready-made triggers: 0

Connect Apache Cassandra / ScyllaDB

In Neblex open Connect › Connections and click New Connection.
Search for Apache Cassandra / ScyllaDB and give the connection a clear name.
Fill in the fields. Secret values are encrypted and never shown again.
Click Test, then Create Connection.

If the system is only reachable inside your network, choose an On-Prem Worker under Test from and run the flow on that Worker. See On-Prem Workers.

Field	What to enter
Contact pointsRequired	One or more nodes of the cluster, separated by commas, as host or host:port. The other nodes are found from these.Example: `cass1.example.com, cass2.example.com:9042`
PortOptional	The CQL port for contact points that name no port. Leave empty for 9042.Example: `9042`
Local datacenterOptional	Send requests only to the nodes of this datacenter, as the cluster's own clients do. Leave empty to use every datacenter.Example: `dc1`
Default keyspaceOptional	Used for tables named without a keyspace in statements and table fields.
UsernameOptional	Leave empty for a cluster without password authentication.
PasswordOptionalSecret
Use TLSOptional	Encrypt the connection to every node. Turn off only for a cluster without client encryption.
Check the certificate nameOptional	Require every node certificate to name the server name below. Turn off for clusters whose node certificates name each node differently; the certificate is still checked against the trusted authorities.
Server nameOptional	The name the node certificates carry. Leave empty to use the first contact point.
Server CA certificate (PEM)Optional	Optional private certificate authority that signed the node certificates. Leave empty for publicly trusted certificates.
Client certificate (PEM)Optional	Only for clusters that require client certificates; enter the private key below as well.
Client private key (PEM)OptionalSecret

Use it in a flow

Open a flow, open the node library and search for Apache Cassandra / ScyllaDB.
Drag it onto the canvas and choose an Operation and your connection.
Map the operation's fields from earlier steps, or click Map with Matt.
Use Test this step to see what it returns, then save.

To start a flow from Apache Cassandra / ScyllaDB without a ready-made trigger: a Poll for changes trigger on Apache Cassandra / ScyllaDB with your own query passes on new or changed records.

Operations

26 operations in 4 groups. Each one is a step you can add to a flow.

Cluster4

Get cluster information`clusterInfo`		Return the cluster name, the coordinator node's version, datacenter, rack, partitioner and protocol versions.
List nodes`listNodes`		List the other nodes the coordinator knows, with their datacenter, rack, version and address.
List table size estimates`listSizeEstimates`		Return the coordinator's estimates of partition count and mean partition size for the token ranges of a table.
Test the connection`ping`		Connect to the cluster, log in and read the node's release version.

CQL4

Run a batch`batch`		Run the CQL write in the statement editor once for every input record, grouped into batches that stay within the cluster's batch size.
Run a query`query`		Run the CQL query in the statement editor with :name values bound from the input.
Run a query page by page`queryPage`		Run the CQL query in the statement editor and return one page of rows with the paging state of the next page, for flows that page themselves.
Run a statement`command`		Run the CQL INSERT, UPDATE, DELETE, TRUNCATE or schema statement in the statement editor with :name values bound from the input.

Rows6

Delete a row`deleteRow`		Delete the row with the primary key you map, or only some of its columns.
Empty a table`truncateTable`		Remove every row of a table on every node.
Find rows`selectRows`		Read the rows of a table whose columns equal the values you map, page by page until every matching row is read.
Get a row`getRow`		Read the row with the primary key you map.
Insert a row`insertRow`		Write one row into a table from the column values you map.
Update a row`updateRow`		Change columns of the row with the primary key you map.

Schema12

Create a keyspace`createKeyspace`		Create a keyspace with its replication strategy.
Delete a keyspace`dropKeyspace`		Delete a keyspace with every table and its data.
Delete a table`dropTable`		Delete a table and its data.
Get schema definition`describeSchema`		Return the CQL statements that create a keyspace, a table, a type, a function or the whole schema, as the cluster describes them (Cassandra 4.0 or later, ScyllaDB 5.2 or later).
List aggregates`listAggregates`		List the user-defined aggregates of a keyspace.
List functions`listFunctions`		List the user-defined functions of a keyspace.
List indexes`listIndexes`		List the secondary indexes of a keyspace or of one table.
List keyspaces`listKeyspaces`		List keyspaces with their replication settings, read page by page.
List materialized views`listMaterializedViews`		List the materialized views of a keyspace with their base table.
List table columns`listColumns`		List the columns of a table with their CQL type and whether they belong to the partition key, the clustering key or are regular columns.
List tables`listTables`		List the tables of one keyspace or of every keyspace, read page by page.
List user-defined types`listUserTypes`		List the user-defined types of a keyspace with their fields.