pluginsplugin-cassandraastradb

Query​Query

Query Astra DB with CQL.

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

Send a CQL query to an Astra DB.

yaml
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 query to execute.

The session connection properties.

Default NONE
Possible Values
STOREFETCHFETCH_ONENONE

The 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.

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.

SubType object

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.

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.

The Astra DB proxy address.

Use it only when you are not using the secure bundle.

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.

Min length 1

The hostname of the Astra DB server.

Default 9042

The port of the Astra DB server.