Stream Processing
Streaming SQL Database
★ 3.8
Real-Time Streaming Data Platform
★ 3.5
N/A — PostgreSQL extensionpip install swimosN/A — PostgreSQL extensionpip install swimosPython 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.
Python data engineers use the SwimOS Python client to connect Python-based data sources and processors to a Swim server's Web Agents. A Python script continuously pushes sensor readings or processed pipeline metrics into Swim agents, which aggregate and stream the live state to connected dashboards via WebSocket — enabling real-time monitoring without a separate WebSocket server.
Individual Tool Pages