Apache Cassandra Query
CertifiedRun a CQL query on Cassandra
Apache Cassandra Query
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.
type: io.kestra.plugin.cassandra.standard.QueryExamples
Send a CQL query to a Cassandra database.
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 *string
CQL query to execute
session *
Cassandra session configuration
Connection settings including endpoints, datacenter, auth, and optional TLS. Required to open the query session.
io.kestra.plugin.cassandra.standard.CassandraDbSession
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).
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.
io.kestra.plugin.cassandra.standard.CassandraDbSession-Endpoint
1Cassandra hostname
9042Cassandra port
Defaults to 9042.
SNI server name
In the context of Cloud, this is the string representation of the host ID.
Local datacenter name
Datacenter considered local by the load-balancing policy; recommended for multi-DC clusters.
Plaintext authentication password
Secure connection details
io.kestra.plugin.cassandra.standard.CassandraDbSession-SecureConnection
Password for the keystore file
Path to keystore file (*.jks)
Password for the truststore file
Path to truststore file (.crt)
Plaintext authentication username
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150fetchType string
NONESTOREFETCHFETCH_ONENONEThe 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.
Outputs
bytes integer
The size of the binary response in bytes
row object
Map containing the first row of fetched data
Only populated when fetchType is FETCH_ONE.
rows array
List of maps containing rows of fetched data
Only populated when fetchType is FETCH.
size integer
The size of the fetched rows
Only populated when fetchType is FETCH or STORE.
uri string
uriThe URI of the result file on Kestra storage (.ion file / Amazon Ion text format)
Only populated when fetchType is STORE.
