Apache Cassandra Query
CertifiedRun a CQL query on Astra DB
Apache Cassandra Query
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.
type: io.kestra.plugin.cassandra.astradb.QueryExamples
Send a CQL query to an Astra DB.
id: cassandra_astradb_query
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.cassandra.astradb.Query
session:
secureBundle: "{{ secret('ASTRADB_SECURE_BUNDLE') }}"
keyspace: astradb_keyspace
clientId: astradb_clientId
clientSecret: "{{ secret('ASTRADB_CLIENT_SECRET') }}"
cql: SELECT * FROM CQL_TABLE
fetchType: FETCH
Properties
cql *string
CQL query to execute
session *
Astra DB session configuration
Connection settings including secure bundle or proxy (choose one), keyspace, and service credentials.
io.kestra.plugin.cassandra.astradb.AstraDbSession
Client ID for Astra DB
Client secret for Astra DB
Keyspace
Astra DB keyspace to connect to
Astra DB cloud proxy address
Use only when the secure bundle is not provided.
io.kestra.plugin.cassandra.astradb.AstraDbSession-ProxyAddress
1Hostname of the Astra DB server
9042Port of the Astra DB server
Base64-encoded secure connect bundle
Supply the ZIP archive content encoded as base64. Use only when not configuring the proxy address.
assets
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.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset 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.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150fetchType string
NONESTOREFETCHFETCH_ONENONEThe 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
bytes integer
The size of the binary response in bytes
row object
Map containing the first row of fetched data
Only populated when fetchType is FETCH_ONE.
rows array
List of maps containing rows of fetched data
Only populated when fetchType is FETCH.
size integer
The size of the fetched rows
Only populated when fetchType is FETCH or STORE.
uri string
uriThe URI of the result file on Kestra storage (.ion file / Amazon Ion text format)
Only populated when fetchType is STORE.
