Query an Astra DB with CQL.
type: "io.kestra.plugin.cassandra.astradb.Query"Send a CQL query to an Astra DB.
id: cassandra_astradb_query
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.cassandra.astradb.Query
session:
secureBundle: /path/to/secureBundle.zip
keyspace: astradb_keyspace
clientId: astradb_clientId
clientSecret: astradb_clientSecret
cql: SELECT * FROM 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.
YESYESYESNOThe Astra DB proxy address.
Use it only when you are not using the secure bundle.
YESThe Astra DB secure bundle, base64 encoded.
It must be the ZIP archive containing the secure bundle encoded in base64. Use it only when you are not using the proxy address.
YES1The hostname of the Astra DB server.
YES9042The port of the Astra DB server.