Show HN: Slipstream – A Python library for stateful stream processing
a year ago
- #data-flow
- #streaming
- #python
- Slipstream通过数据流模型简化了有状态的流式应用程序开发
- 核心特性包括开发过程的简洁性、自由度和高效性
- 支持消费任何异步可迭代数据源（如Kafka或流式API）
- 可将数据输出或缓存至任意可调用对象（包括Kafka或RocksDB）
- 支持用Python实现任意有状态操作（连接、聚合、过滤等）
- 能够检测流中断并管理依赖流或校正流程
- 展示了轻松创建框架级功能（如定时器）的能力
- 示例演示了用`slipstream.handle`绑定数据源/输出端并生成数据
- 运行`slipstream.stream`即可启动从数据源到输出端的流式传输