Streaming Events From PostgreSQL Clients

PipelineDB works with any clients that work with PostgreSQL, or any standard SQL client for that matter.

Below are examples of streaming events into a continuous view from a few popular languages. Continuous views are the core abstraction of PipelineDB. You can think about them as very high-throughput, realtime, incrementally updated materialized views. The most important property of a continuous view is that only its output is actually stored in the database.

Note that the stream that these clients write to is not predeclared. This is possible because we're specifying column names and types inline using :: casting syntax. When column names and types are specified inline, PipelineDB infers the correct schema to apply to incoming events.