ESC
Ask Kestra AI
ESC
Kestra AI

Hi! I'm your Kestra AI assistant.
Ask me anything about workflows.

EXAMPLE QUESTIONS

How to handle errors & retry on flow?
How to add secrets?
How to run a Ansible playbook?

ScyllaDB Queries

ScyllaDB Queries

Certified

Execute SELECT statements sequentially in ScyllaDB

Runs SELECT statements in their supplied order using one session, returning one output per statement. Queries do not share a transactional snapshot.

yaml
type: io.kestra.plugin.scylladb.Queries

Read cluster and data center information in order

yaml
id: scylladb_queries
namespace: company.team

tasks:
  - id: queries
    type: io.kestra.plugin.scylladb.Queries
    connection:
      contactPoints:
        - "{{ secret('SCYLLADB_HOST') }}:9042"
      localDatacenter: datacenter1
      username: "{{ secret('SCYLLADB_USERNAME') }}"
      password: "{{ secret('SCYLLADB_PASSWORD') }}"
    cql:
      - SELECT cluster_name FROM system.local
      - SELECT data_center FROM system.local
    fetchType: FETCH_ONE
    fetchSize: 100
Properties

Native CQL connection settings, including contact points, local datacenter, authentication, and optional TLS.

Definitions

Native CQL connection settings rendered at task execution.

contactPoints*array
SubTypestring

Contact points

Non-empty list of hosts, host: port, or [IPv6]: port addresses. The default port is 9042.

localDatacenter*string

Local datacenter

Datacenter used by the driver's load balancing policy, for example datacenter1.

keyspacestring

Keyspace

Optional default keyspace. Omit when creating a keyspace with DDL.

keystorePasswordstring
Formatpassword

Client keystore password

Optional client keystore password. Requires keystorePath. Use a Kestra secret expression.

keystorePathstring

Client keystore path

Optional JKS client keystore path on the worker filesystem for mutual TLS. Requires TLS.

passwordstring
Formatpassword

Password

Native CQL authentication password. Use a Kestra secret expression.

requestTimeoutstring

Request timeout

Optional strictly positive CQL request timeout as an ISO-8601 duration, for example PT30S. Otherwise the driver default applies.

tlsEnabledbooleanstring
Defaultfalse

Enable TLS

Enable certificate and hostname verification. Uses JVM trust roots unless a truststore is supplied.

truststorePasswordstring
Formatpassword

Truststore password

Optional truststore password. Requires truststorePath. Use a Kestra secret expression.

truststorePathstring

Truststore path

Optional JKS truststore path on the worker filesystem. Requires TLS.

usernamestring

Username

Native CQL authentication username. Set together with password; secret expressions are supported.

SubTypestring

Ordered CQL statements

A non-empty list of non-blank SELECT statements. All statements are rendered and validated before the first is executed. Named : name markers bind the shared parameters map.

Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.

Definitions
assetFailureBehaviorstring
Possible Values
IGNOREFAILWARN

Asset failure behavior

Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.

enableAutobooleanstring

Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.

inputsarray

The assets consumed as inputs.

id*string
Min length1
typestring
outputs

The assets produced as outputs.

id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*object
descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150
id*string
Min length1
Max length150
type*string
Min length1

Custom asset type

descriptionstring
displayNamestring
metadataobject
Default{}
namespacestring
Min length1
Max length150

Driver page size

Optional positive page size applied to every statement. This does not limit the total number of rows; FETCH and STORE consume all pages.

DefaultFETCH
Possible Values
STOREFETCHFETCH_ONENONE

Result fetch mode

Applied to every statement: FETCH returns all rows, FETCH_ONE returns at most one, STORE streams rows to a separate Ion file per statement.

Bound parameters

Values for named : name markers in cql. Each value is rendered, then bound to a prepared statement using that marker's CQL type. Use this for flow inputs and upstream outputs instead of interpolating them into the statement text. Keys that are not markers of a statement are ignored.

Ordered statement results

One Query output per CQL statement, in the same order as the input statements.

Definitions
rowobject

First fetched row

Populated for FETCH_ONE; null when the result is empty.

rowsarray
SubTypeobject

All fetched rows

Populated for FETCH in result order, including all pages.

sizeinteger

Number of emitted rows

Zero or one for FETCH_ONE, or the total row count for FETCH and STORE.

uristring
Formaturi

Stored result URI

Internal storage URI of the Ion file, populated for STORE.

More Plugins in this Category

Arrow Flight
Arrow Flight

Tasks that connect to Apache Arrow Flight SQL via JDBC to run queries and loads.

DataInfrastructure

3 tasks

Twilio
Twilio

Tasks that integrate with the Twilio ecosystem.

BusinessData

9 tasks

3 blueprints