Slipstream:简化有状态流式应用开发的数据流模型
2025-04-03
Slipstream是一个使用Python构建的数据流模型,旨在简化有状态流式应用程序的开发。它支持多种数据源(如Kafka、流式API)和数据接收器(如Kafka、RocksDB、API),并允许使用普通的Python代码进行任意状态化操作(连接、聚合、过滤)。通过一个简单的计时器示例演示了其易用性,只需几行代码即可实现定时任务。Slipstream的核心在于其简洁性、灵活性和速度,通过优化的默认配置快速启动并运行。
开发