Back to destination list
Official
DuckDB destination integration documentation
This destination plugin lets you sync data from a CloudQuery source to DuckDB (self-hosted or MotherDuck-compatible).
Loading plugin documentation
This destination plugin lets you sync data from a CloudQuery source to DuckDB (self-hosted or MotherDuck-compatible).
Loading plugin documentation
CloudQuery's use of cookies
We use tracking cookies to understand how you use the product and help us improve it. Please accept cookies to help us improve. You can always opt out later via the link in the footer.
./database.db in the local directory.kind: destination
spec:
name: duckdb
path: cloudquery/duckdb
registry: cloudquery
version: "v6.3.0"
write_mode: "overwrite-delete-stale"
send_sync_summary: true
# Learn more about the configuration options at https://cql.ink/duckdb_destination
spec:
connection_string: ./database.db
# Optional parameters
# batch_size: 1000
# batch_size_bytes: 4194304 # 4 MiB
# debug: false
cloudquery sync, you can explore the data locally with the DuckDB CLI: duckdb ./database.db.write_mode is overwrite-delete-stale, but the plugin also supports overwrite or append. Note that overwrite and overwrite-delete-stale modes do not support atomic updates: to update a resource, it is first deleted and then re-inserted. This is due to a current lack of support in DuckDB for upserting list-type columns. If this is an issue for you, consider using the append mode instead. You may then perform a manual cleanup of stale resources after the sync completes.connection_string (string) (required)./example.duckdb.batch_size (integer) (optional) (default: 1000)batch_size_bytes (integer) (optional) (default: 4194304 (4 MiB))debug (boolean) (optional) (default: false)md: prefix to indicate syncing to the MotherDuck data warehouse and add the service token using the motherduck_token query string. We recommend passing the service token using variable expansion like this:spec:
connection_string: "md:my_db?motherduck_token=${MOTHERDUCK_TOKEN}"
uinteger, ubigint)integer[])timestamp for compatibilityvarchar for storage, losing their structured nature