Examples

Real pipelines. No infrastructure.

Real pipelines. No infrastructure.

These examples show how to build complete data workflows with OndatraSQL — from ingestion to analytics.

Each example is a working model you can run locally.

Ingestion

Fetch data from APIs or collect events — no connectors, no brokers.

• Ingest from a REST API — No Python. No connectors. No scheduler.
• YAML Model with Shared Library — Reusable source functions for any API.
• Track Product Analytics — No Kafka. No external event tools.

Transformation

Use SQL models to clean, join, and reshape your data.

• Build Daily Metrics — Three-layer pipeline: raw → staging → mart.
• Incremental SQL Model — Append new data automatically with cursor tracking.

Change Tracking

Handle updates, history, and incremental processing automatically.

• SCD2 Dimension — Track full history of dimension changes.

Validation

Ensure your data is correct before and after it’s written.

• Validated Model — Constraints, audits, and warnings in one model.

Try It Yourself

Pick any example, copy it into a new project, and run:

ondatrasql run

That’s it.