Apache Cassandra Query

Apache Cassandra Query

Certified

Run a CQL query on Cassandra

Executes a CQL statement against Cassandra. Use fetchType to control result handling (FETCH, STORE, FETCH_ONE); NONE is the default and only records metrics.

yaml
type: io.kestra.plugin.cassandra.standard.Query

Send a CQL query to a Cassandra database.

yaml
id: cassandra_standard_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.cassandra.standard.Query
    session:
      endpoints:
        - hostname: localhost
      secureConnection:
        truststorePath: path to .crt file
        truststorePassword: "{{ secret('TRUSTSTORE_PASSWORD') }}"
        keystorePath: path to .jks file
        keystorePassword: "{{ secret('KEYSTORE_PASSWORD') }}"
      username: cassandra_user
      password: "{{ secret('CASSANDRA_PASSWORD') }}"
    cql: SELECT * FROM CQL_KEYSPACE.CQL_TABLE
    fetchType: FETCH
Properties

CQL query to execute

Cassandra session configuration

Connection settings including endpoints, datacenter, auth, and optional TLS. Required to open the query session.

Definitions
applicationNamestring

Application name sent in startup

It will be sent in the STARTUP protocol message, under the key APPLICATION_NAME, for each new connection established by the driver. Currently, this information is used by Insights monitoring (if the target cluster does not support Insights, the entry will be ignored by the server).

endpointsarray

Contact endpoints for cluster bootstrap

List of hosts (and optional SNI names) used to open the initial connection. Port defaults to 9042 per endpoint unless overridden.

hostname*Requiredstring
Min length1

Cassandra hostname

portintegerstring
Default9042

Cassandra port

Defaults to 9042.

serverNamestring

SNI server name

In the context of Cloud, this is the string representation of the host ID.

localDatacenterstring

Local datacenter name

Datacenter considered local by the load-balancing policy; recommended for multi-DC clusters.

passwordstring

Plaintext authentication password

secureConnection

Secure connection details

keystorePasswordstring

Password for the keystore file

keystorePathstring

Path to keystore file (*.jks)

truststorePasswordstring

Password for the truststore file

truststorePathstring

Path to truststore file (.crt)

usernamestring

Plaintext authentication username

DefaultNONE
Possible Values
STOREFETCHFETCH_ONENONE

The way you want to store data

FETCH_ONE - output the first row. FETCH - output all rows as output variable. STORE - store all rows to a file. NONE - do nothing.

Reference (ref) of the pluginDefaults to apply to this task.

The size of the binary response in bytes

Map containing the first row of fetched data

Only populated if 'fetchOne' parameter is set to true.

SubTypeobject

Lit of map containing rows of fetched data

Only populated if 'fetch' parameter is set to true.

The size of the fetched rows

Only populated if 'store' or 'fetch' parameter is set to true.

Formaturi

The url of the result file on kestra storage (.ion file / Amazon Ion text format)

Only populated if 'store' is set to true.

More Plugins in this Category

Clickhouse
Clickhouse

Tasks that connect to ClickHouse via JDBC to run queries and loads.

Data

5 tasks

2 blueprints

Weaviate
Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

4 tasks

2 blueprints