Query
type: "io.kestra.plugin.cassandra.Query"
Query a Cassandra database with CQL.
Examples
Send a cql query to a Cassandra database
id: "query"
type: "io.kestra.plugin.cassandra.Query"
session:
endpoints:
- hostname: localhost
username: cassandra_user
password: cassandra_passwd
cql: SELECT * FROM CQL_KEYSPACE.CQL_TABLE
Properties
cql
- Type: string
- Dynamic: ✔️
- Required: ✔️
CQL query to execute
session
- Type: CassandraDbSession
- Dynamic: ❌
- Required: ✔️
The session connection properties
fetch
- Type: boolean
- Dynamic: ❌
- Required: ❌
- Default:
false
Whether to Fetch the data from the query result to the task output
fetchOne
- Type: boolean
- Dynamic: ❌
- Required: ❌
- Default:
false
Whether to Fetch only one data row from the query result to the task output
store
- Type: boolean
- Dynamic: ❌
- Required: ❌
- Default:
false
Whether to store the data from the query result into an ion serialized data file
Outputs
bytes
- Type: integer
The size of the binary response in bytes.
row
- Type: object
Map containing the first row of fetched data
Only populated if 'fetchOne' parameter is set to true.
rows
- Type: array
- SubType: object
Lit of map containing rows of fetched data
Only populated if 'fetch' parameter is set to true.
size
- Type: integer
The size of the fetched rows
Only populated if 'store' or 'fetch' parameter is set to true.
uri
- Type: string
The url of the result file on kestra storage (.ion file / Amazon Ion text format)
Only populated if 'store' is set to true.
Definitions
Endpoint
hostname
- Type: string
- Dynamic: ✔️
- Required: ✔️
- Min length:
1
The hostname of the Cassandra server
port
- Type: integer
- Dynamic: ❌
- Required: ✔️
- Default:
9042
The port of the Cassandra server
serverName
- Type: string
- Dynamic: ✔️
- Required: ❌
The SNI server name
In the context of Cloud, this is the string representation of the host id.
CassandraDbSession
applicationName
- Type: string
- Dynamic: ✔️
- Required: ❌
The 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).
endpoints
- Type: array
- SubType: Endpoint
- Dynamic: ✔️
- Required: ❌
List of contact endpoints to use for the initial connection to the cluster.
localDatacenter
- Type: string
- Dynamic: ✔️
- Required: ❌
Specifies the datacenter that is considered "local" by the load balancing policy.
password
- Type: string
- Dynamic: ✔️
- Required: ❌
Plaintext authentication password
username
- Type: string
- Dynamic: ✔️
- Required: ❌
Plaintext authentication username