Wait for a query to return results on a Cassandra database.

Wait for a CQL query to return results, and then iterate through rows.

yaml
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"
    fetchType: FETCH

CQL query.

The session connection properties

SubType

List of conditions in order to limit the flow trigger.

Default false

DEPRECATED, please use fetchType: FETCH instead.Whether to fetch the data from the query result to the task output.

Default false

DEPRECATED, please use fetchType: FETCH_ONE instead.Whether to fetch only one data row from the query result to the task output.

Default NONE

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.

Default 60

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

SubType string

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

List of execution states after which a trigger should be stopped (a.k.a. disabled).

Default false

DEPRECATED, please use fetchType: STORE instead.Whether to store the data from the query result into an ion serialized data file.

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.

SubType object

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.

Format uri

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)

Min length 1

The hostname of the Cassandra server.

Default 9042

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

SubType

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

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

Plaintext authentication password.

Secure connection details.

Plaintext authentication username.

​Trigger

Trigger