Query a Cassandra database with CQL.
type: "io.kestra.plugin.cassandra.standard.Query"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: truststore_password
keystorePath: path to .jks file
keystorePassword: keystore_password
username: cassandra_user
password: cassandra_passwd
cql: SELECT * FROM CQL_KEYSPACE.CQL_TABLE
fetchType: FETCH
YESCQL query to execute.
NOThe session connection properties.
YESfalseDEPRECATED, please use fetchType: FETCH instead.Whether to fetch the data from the query result to the task output.
YESfalseDEPRECATED, please use fetchType: FETCH_ONE instead.Whether to fetch only one data row from the query result to the task output.
YESNONESTOREFETCHFETCH_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.
YESfalseDEPRECATED, please use fetchType: STORE instead.Whether to store the data from the query result into an ion serialized data file.
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.
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.
uriThe url of the result file on kestra storage (.ion file / Amazon Ion text format)
Only populated if 'store' is set to true.
YESPassword for the keystore file.
YESPath to the keystore file. (*.jks)
YESPassword for the truststore file.
YESPath to the truststore file. (.crt)
YES1The hostname of the Cassandra server.
YES9042The port of the Cassandra server.
YESThe SNI server name.
In the context of Cloud, this is the string representation of the host ID.
YESThe name of the application using the created session.
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).
YESSpecifies the datacenter that is considered "local" by the load balancing policy.
YESPlaintext authentication password.
YESSecure connection details.
YESPlaintext authentication username.