PluginsApache CassandraTriggersAstradb

Trigger​Trigger

yaml
type: "io.kestra.plugin.cassandra.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: 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

Properties

cql

  • Type: string
  • Dynamic: ❌
  • Required: ✔️

CQL query.

session

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

stopAfter

  • Type: array
  • SubType: string
  • Dynamic: ❌
  • Required: ❌

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

store

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

Whether to store the data from the query result into an ion serialized data file.

timeZoneId

  • Type: string
  • Dynamic: ❌
  • Required: ❌

Outputs

bytes

  • Type: integer
  • Required: ❌

row

  • Type: object
  • Required: ❌

rows

  • Type: array
  • SubType: object
  • Required: ❌

size

  • Type: integer
  • Required: ❌

uri

  • Type: string
  • Required: ❌
  • Format: uri

Definitions

io.kestra.plugin.cassandra.astradb.AstraDbSession

  • clientId
    • Type: string
    • Dynamic: ✔️
    • Required: ✔️
  • clientSecret
    • Type: string
    • Dynamic: ✔️
    • Required: ✔️
  • keyspace
    • Type: string
    • Dynamic: ✔️
    • Required: ✔️
  • proxyAddress
  • secureBundle
    • Type: string
    • Dynamic: ✔️
    • Required: ❌

io.kestra.plugin.cassandra.astradb.AstraDbSession-ProxyAddress

  • hostname
    • Type: string
    • Dynamic: ✔️
    • Required: ✔️
    • Min length: 1
  • port
    • Type: integer
    • Dynamic: ❌
    • Required: ✔️
    • Default: 9042