Duckdb
Certified
Tasks that connect to DuckDB via JDBC to run queries and loads.

Provide the DuckDB JDBC URL, credentials (if any), and SQL statements (query, batch, load, trigger) to read or write data; configure fetch type, fetch size, and output options to return rows or files from workflows.

tasks

Queries

Execute multiple SQL statements against DuckDB

io.kestra.plugin.jdbc.duckdb.Queries

Query

Execute a single SQL query against DuckDB

io.kestra.plugin.jdbc.duckdb.Query

triggers

Trigger

Wait for query results on DuckDB and trigger flow

io.kestra.plugin.jdbc.duckdb.Trigger

DuckDB tasks run SQL directly inside DuckDB. You can query in-memory data, local files provided through inputFiles, and files or tables exposed by DuckDB extensions and functions.

Write standard DuckDB SQL in the task sql property. For self-contained workflows, a common pattern is to provide small datasets with inputFiles and query them directly from the task.

Bundled Ion extension

This plugin also bundles the DuckDB ion extension, so Amazon Ion files can be read with read_ion(...) without installing anything separately.

This is useful in Kestra because some task outputs and internal data exchanges use Ion-compatible files, which can then be queried directly from DuckDB tasks.

For simple cases, schema inference works automatically:

SELECT *
FROM read_ion('sample.ion');

For nested or inconsistent Ion records, defining columns: = {...} is recommended because it makes the schema explicit and avoids inference surprises:

id: duckdb-ion
namespace: company.team

tasks: 
  - id: query
    type: io.kestra.plugin.jdbc.duckdb.Query
    inputFiles: 
      sample.ion: |
        {id: 1, nested: {name: "alpha"}, tags: ["x", "y"]}
        {id: 2, nested: {name: "beta"}, tags: ["z"]}
    sql: |
      SELECT id, nested.name, list_extract(tags, 1) AS first_tag
      FROM read_ion('sample.ion', columns: = {
        id: 'BIGINT',
        nested: 'STRUCT(name VARCHAR)',
        tags: 'VARCHAR[]'
      })
      ORDER BY id

read_ion also supports globs and lists of files. When reading multiple files with varying schemas, union_by_name: = true can help merge fields by name.