Query
Query Astra DB with CQL.
type: "io.kestra.plugin.cassandra.astradb.Query"Examples
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
Properties
cql*Requiredstring
CQL query to execute.
session*RequiredNon-dynamic
The session connection properties.
io.kestra.plugin.cassandra.astradb.AstraDbSession
The Astra DB proxy address.
Use it only when you are not using the secure bundle.
io.kestra.plugin.cassandra.astradb.AstraDbSession-ProxyAddress
1The hostname of the Astra DB server.
9042The port of the Astra DB server.
The 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.
fetchTypestring
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
bytesinteger
The size of the binary response in bytes.
rowobject
Map containing the first row of fetched data
Only populated if 'fetchOne' parameter is set to true.
rowsarray
Lit of map containing rows of fetched data
Only populated if 'fetch' parameter is set to true.
sizeinteger
The size of the fetched rows
Only populated if 'store' or 'fetch' parameter is set to true.
uristring
uriThe url of the result file on kestra storage (.ion file / Amazon Ion text format)
Only populated if 'store' is set to true.
