Apache Cassandra Query

Apache Cassandra Query

Certified

Run a CQL query on Astra DB

Executes a CQL statement against Astra DB. Use fetchType to control result handling (FETCH, STORE, FETCH_ONE); NONE is the default and only records metrics.

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: "{{ secret('ASTRADB_CLIENT_SECRET') }}"
    cql: SELECT * FROM CQL_TABLE
    fetchType: FETCH
Properties

CQL query to execute

Astra DB session configuration

Connection settings including secure bundle or proxy (choose one), keyspace, and service credentials.

Definitions
clientId*Requiredstring

Client ID for Astra DB

clientSecret*Requiredstring

Client secret for Astra DB

keyspace*Requiredstring
proxyAddress

Astra DB cloud proxy address

Use only when the secure bundle is not provided.

hostname*Requiredstring
Min length1

Hostname of the Astra DB server

portintegerstring
Default9042

Port of the Astra DB server

secureBundlestring

Base64-encoded secure connect bundle

Supply the ZIP archive content encoded as base64. Use only when not configuring the proxy address.

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

Reference (ref) of the pluginDefaults to apply to this task.

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.

SubTypeobject

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.

Formaturi

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

Only populated if 'store' is set to true.

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints