Trigger

yaml

type: "io.kestra.plugin.astradb.Trigger"

Wait for a query to return results on Astra DB.

Examples

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

yaml

id: astra-trigger
namespace: io.kestra.tests
tasks:
  - id: each
    type: io.kestra.core.tasks.flows.EachSequential
    tasks:
      - id: return
        type: io.kestra.core.tasks.debugs.Return
        format: "{{ json(taskrun.value) }}"
    value: "{{ trigger.rows }}"

triggers:
  - id: watch
    type: io.kestra.plugin.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

Properties

`cql`

Type: string
Dynamic: ❌
Required: ✔️

CQL query.

`session`

Type: AstraDbSession
Dynamic: ❌
Required: ✔️

The session connection properties.

`conditions`

Type: array
SubType: Condition
Dynamic: ❌
Required: ❌

List of conditions in order to limit the flow trigger.

`fetch`

Type: boolean
Dynamic: ❌
Required: ❌
Default: false

Whether to fetch the data from the query result to the task output.

`fetchOne`

Type: boolean
Dynamic: ❌
Required: ❌
Default: false

Whether to fetch only one data row from the query result to the task output.

`interval`

Type: string
Dynamic: ❌
Required: ❌
Default: 60.000000000
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.