PLUGINSPLUGIN-CASSANDRATASKSIO.KESTRA.PLUGIN.CASSANDRA.QUERY

​Query

Query Query

yaml
type: "io.kestra.plugin.cassandra.Query"

Query a Cassandra database with CQL.

Examples

Send a cql query to a Cassandra Database

yaml
id: "query"
type: "io.kestra.plugin.cassandra.Query"
session:
  host: 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

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 cassandra server

port

  • Type: integer
  • Dynamic: ❌
  • Required: ✔️
  • Default: 9042

The port of 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: ❌

Adds contact points 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