Trigger
Wait for a query to return results on Astra DB.
type: "io.kestra.plugin.cassandra.astradb.Trigger"
Wait for a CQL query to return results, and then iterate through rows.
id: astra_trigger
namespace: company.team
tasks:
- id: each
type: io.kestra.core.tasks.flows.ForEach
values: "{{ trigger.rows }}"
tasks:
- id: return
type: io.kestra.core.tasks.debugs.Return
format: "{{ json(taskrun.value) }}"
triggers:
- id: watch
type: io.kestra.plugin.cassandra.astradb.Trigger
interval: "PT5M"
session:
secureBundle: /path/to/secureBundle.zip
keyspace: astradb_keyspace
clientId: astradb_clientId
clientSecret: astradb_clientSecret
cql: "SELECT * FROM CQL_KEYSPACE.CQL_TABLE"
fetchType: FETCH
YES
CQL query.
NO
The session connection properties.
YES
false
DEPRECATED, please use fetchType: FETCH
instead.Whether to fetch the data from the query result to the task output.
YES
false
DEPRECATED, please use fetchType: FETCH_ONE
instead.Whether to fetch only one data row from the query result to the task output.
YES
NONE
STORE
FETCH
FETCH_ONE
NONE
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.
NO
60
duration
Interval between polling.
The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.
NO
CREATED
RUNNING
PAUSED
RESTARTED
KILLING
SUCCESS
WARNING
FAILED
KILLED
CANCELLED
QUEUED
RETRYING
RETRIED
SKIPPED
List of execution states after which a trigger should be stopped (a.k.a. disabled).
YES
false
DEPRECATED, please use fetchType: STORE
instead.Whether to store the data from the query result into an ion serialized data file.
NO
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.
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.
uri
The url of the result file on kestra storage (.ion file / Amazon Ion text format)
Only populated if 'store' is set to true.
YES
YES
YES
NO
The Astra DB proxy address.
Use it only when you are not using the secure bundle.
YES
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.
YES
1
The hostname of the Astra DB server.
YES
9042
The port of the Astra DB server.