Wait for a query to return results on Astra DB.

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

yaml
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"
    fetch: true

Dynamic YES

CQL query.

Dynamic NO

The session connection properties.

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

Dynamic YES

Default false

Dynamic YES

Default false

Dynamic NO

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

Dynamic NO

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

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

Dynamic YES

Default false

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

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.

Dynamic YES

Dynamic NO

The Astra DB proxy address.

Use it only when you are not using the secure bundle.

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

Dynamic YES

Min length 1

The hostname of the Astra DB server.

Dynamic YES

Default 9042

​Trigger

Trigger