Couchbase
CertifiedTasks that execute Couchbase N1QL queries and trigger Kestra flows from query results.
Run Couchbase operations from Kestra with the Query task for on-demand N1QL execution and the Trigger to poll queries on a schedule. Supply the database connection string, username, password, and query; optional parameters and fetchType control whether rows are returned, a single row is provided, or results are stored for downstream tasks.
Couchbase
Certified
Tasks that execute Couchbase N1QL queries and trigger Kestra flows from query results.
Run Couchbase operations from Kestra with the Query task for on-demand N1QL execution and the Trigger to poll queries on a schedule. Supply the database connection string, username, password, and query; optional parameters and fetchType control whether rows are returned, a single row is provided, or results are stored for downstream tasks.
This plugin runs N1QL queries against a Couchbase cluster and lets a flow react to query results.
Tasks
Queryexecutes a N1QL statement and captures the result. SetfetchTypeto:FETCHto return all rows inline in the task output,FETCH_ONEto return only the first row,STOREto write the full result set to Kestra internal storage as an ion file.
Triggers
Triggerpolls a N1QL query on an interval and starts an execution when it returns rows.
Connection
Connect with a connectionString (for example couchbase://localhost), a username, and a password.
Provide the password and any other credentials through {{ secret('...') }} rather than inline values.
