Query a Couchbase database on regular intervals, and trigger flow on results.

yaml
type: "io.kestra.plugin.couchbase.trigger"

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

yaml
id: couchbase_trigger
namespace: company.team

tasks:
  - id: each
    type: io.kestra.plugin.core.flow.ForEach
    values: "{{ trigger.rows }}"
    tasks:
      - id: return
        type: io.kestra.plugin.core.debug.Return
        format: "{{ json(taskrun.value) }}"

triggers:
  - id: watch
    type: io.kestra.plugin.couchbase.Trigger
    interval: "PT5M"
    connectionString: couchbase://localhost
    username: couchbase_user
    password: couchbase_passwd
    query: SELECT * FROM `COUCHBASE_BUCKET`(.`COUCHBASE_SCOPE`.`COUCHBASE_COLLECTION`)
    fetchType: FETCH

Min length 1

Connection string used to locate the Couchbase cluster.

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.

Min length 1

N1QL query to execute on Couchbase database.

Min length 1

Plaintext authentication username.

SubType

List of conditions in order to limit the flow trigger.

Default STORE

Possible Values

STOREFETCHFETCH_ONENONE

The way you want to fetch and/or store the data.

FETCH_ONE - output just the first row. FETCH - output all the rows. STORE - store all the rows in a file. NONE - do nothing.

SubType string

Query parameters, can be positional or named parameters.

See Couchbase documentation about Prepared Statements for query syntax. This should be supplied with a parameter map if using named parameters, or an array for positional ones.

Min length 1

Plaintext authentication password.

SubType string

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

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

Map containing the first row of fetched data.

Only populated if using FETCH_ONE.

SubType object

List containing the fetched data.

Only populated if using FETCH.

The number of rows to be fetched.

Only populated if fetchType is 'FETCH' or 'STORE'.

Format uri

The URI of the stored result in Kestra's internal storage.

Only populated if using STORE.