Trigger
Wait for a query to return results on a Cassandra database.
type: "io.kestra.plugin.cassandra.standard.Trigger"Wait for a CQL query to return results, and then iterate through rows.
id: cassandra_trigger
namespace: io.kestra.tests
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.standard.Trigger
interval: "PT5M"
session:
endpoints:
- hostname: localhost
username: cassandra_user
password: cassandra_passwd
cql: "SELECT * FROM CQL_KEYSPACE.CQL_TABLE"
fetch: true
CQL query.
The session connection properties
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.
List of execution states after which a trigger should be stopped (a.k.a. disabled).
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.
The url of the result file on kestra storage (.ion file / Amazon Ion text format)
Only populated if 'store' is set to true.
Password for the keystore file.
Path to the keystore file. (*.jks)
Password for the truststore file.
Path to the truststore file. (.crt)
The hostname of the Cassandra server.
The SNI server name.
In the context of Cloud, this is the string representation of the host ID.
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).
Specifies the datacenter that is considered "local" by the load balancing policy.
Plaintext authentication password.
Secure connection details.
Plaintext authentication username.