设计概要： - 把数据流形象话的比作水流 - 使用redis流和流的存储功能做水库，分别设计进水和出水系统 - 使用tornado可以同时支持多个进出水水管并行运行，互不干扰 - 使用streamz库灵活实现加在进出水管上的算法，可以实现限速rate_limit、过滤filter、批处理map，合并zip，缓冲buffer等特性

more ...