Slipstream 使用数据流模型简化了有状态流式应用程序的开发。它通过并行处理和灵活的源/宿映射提供简洁性,同时允许自由使用任意 Python 代码而无需限制性抽象。通过优化的默认设置,快速启动即可实现高速运行。
Slipstream 消费任何 Async Iterable 源(例如,Kafka,流式 API)并将数据输出到任何 Callable(例如,Kafka,RocksDB,API)。用户可以使用标准 Python 代码执行有状态操作,例如连接、聚合和过滤。还提供依赖流宕机检测以及暂停/纠正功能。
利用基本的 Python 构建块,Slipstream 能够轻松创建类似框架的功能,例如定时器。示例演示了一个定时器触发一个处理程序,该处理程序向打印宿输出 "🐟 - blub",说明了轻松创建具有源、处理程序和宿的流。