query
Query a Cassandra database with CQL.

Query a Cassandra database with CQL.

yaml
type: "io.kestra.plugin.cassandra.standard.query"

Examples

Send a CQL query to a Cassandra database.

yaml
id: cassandra_standard_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.cassandra.standard.Query
    session:
      endpoints:
        - hostname: localhost
      secureConnection:
        truststorePath: path to .crt file
        truststorePassword: truststore_password
        keystorePath: path to .jks file
        keystorePassword: keystore_password
      username: cassandra_user
      password: cassandra_passwd
    cql: SELECT * FROM CQL_KEYSPACE.CQL_TABLE
    fetchType: FETCH

Properties

cql*string

CQL query to execute.

session*

The session connection properties.

Definitions

io.kestra.plugin.cassandra.standard.CassandraDbSession

applicationNamestring

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

endpointsarray

List of contact endpoints to use for the initial connection to the cluster.

io.kestra.plugin.cassandra.standard.CassandraDbSession-Endpoint

hostname*string

Min length1

The hostname of the Cassandra server.

portintegerstring

Default9042

The port of the Cassandra server.

serverNamestring

The SNI server name.

In the context of Cloud, this is the string representation of the host ID.

localDatacenterstring

Specifies the datacenter that is considered "local" by the load balancing policy.

passwordstring

Plaintext authentication password.

secureConnection

Secure connection details.

io.kestra.plugin.cassandra.standard.CassandraDbSession-SecureConnection

keystorePasswordstring

Password for the keystore file.

keystorePathstring

Path to the keystore file. (*.jks)

truststorePasswordstring

Password for the truststore file.

truststorePathstring

Path to the truststore file. (.crt)

usernamestring

Plaintext authentication username.

fetchTypestring

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.

Outputs

bytesinteger

The size of the binary response in bytes.

rowobject

Map containing the first row of fetched data

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

rowsarray

SubTypeobject

Lit of map containing rows of fetched data

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

sizeinteger

The size of the fetched rows

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

uristring

Formaturi

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

Only populated if 'store' is set to true.

Mariadb

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

Database

Opensearch

Enterprise

This sub-group of plugins contains tasks for using Opensearch EE. Opensearch is a distributed, RESTful search and analytics engine capable of addressing a growing number of use cases.

Database