PipelineDB

About PipelineDB

A streaming SQL database that runs SQL queries continuously on incoming data streams. PipelineDB is built as a PostgreSQL extension, allowing you to use standard SQL to define continuous views over streaming data for real-time analytics.

Key Features

• 1Streaming SQL database that continuously runs queries on incoming data
• 2Continuous views materialize query results as new data arrives
• 3Built as a PostgreSQL extension — fully SQL-compatible
• 4Sliding window aggregations using time-based stream triggers
• 5Combines with a standard PostgreSQL database for historical and live queries

How Python Data Engineers Use PipelineDB

Python data engineers use PipelineDB via standard `psycopg2` connections — defining continuous views in SQL that automatically aggregate incoming rows. A Python ingestion process writes events to PipelineDB streams using standard INSERT statements, and the continuous view query results update in real time, making precomputed aggregates instantly available for dashboards.