Show HN: Slipstream – A Python library for stateful stream processing
a year ago
- #data-flow
- #streaming
- #python
- Slipstream simplifies stateful streaming applications with a data-flow model.
- Key features include simplicity, freedom, and speed in development.
- Supports consuming any Async Iterable source like Kafka or streaming APIs.
- Allows sinking or caching data to any Callable, including Kafka or RocksDB.
- Enables arbitrary stateful operations (joining, aggregating, filtering) with Python.
- Can detect stream downtimes and manage dependent streams or corrections.
- Demonstrates ease of creating framework-like features, e.g., a timer.
- Example shows binding sources/sinks with `slipstream.handle` and yielding data.
- Running `slipstream.stream` initiates the data flow from sources to sinks.