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:
  endpoints:
    - hostname: localhost
  username: cassandra_user
  password: cassandra_passwd
cql: SELECT * FROM CQL_KEYSPACE.CQL_TABLE
fetch: true

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
  • Dynamic:
  • Required:

The size of the binary response in bytes.

row

  • Type: object
  • Dynamic:
  • Required:

Map containing the first row of fetched data

Only populated if 'fetchOne' parameter is set to true.

rows

  • Type: array
  • SubType: object
  • Dynamic:
  • Required:

Lit of map containing rows of fetched data

Only populated if 'fetch' parameter is set to true.

size

  • Type: integer
  • Dynamic:
  • Required:

The size of the fetched rows

Only populated if 'store' or 'fetch' parameter is set to true.

uri

  • Type: string
  • Dynamic:
  • Required:
  • Format: uri

The url of the result file on kestra storage (.ion file / Amazon Ion text format)

Only populated if 'store' is set to true.

Definitions

io.kestra.plugin.cassandra.CassandraDbSession-Endpoint

Properties

hostname
  • Type: string
  • Dynamic: ✔️
  • Required: ✔️
  • <