from_coroutine 和from_future

1. 上游异步任务交到流会自动被执行，并且将结果push到下游
2. 上游异步任务必须是coroutine或者future，异步的异步的网络抓取函数或者数据库写入函数的执行结果
3. 协程执行结果进入下游是无序的

需求

存储py对象时，有几个要注意 1. 实际存储路径，格式，备份 2. 存储具体的子目录，tags 3. 存储的key和value

查询时，按照子目录、key、tag其中组合查找

定义好某个数据流后,可以按照路由规则,将数据流中的特定数据分流给特定函数去处理,这时的数据流中的数据,类似于事件系统中的事件的概念,而路由处理函数,相当于是事件处理函数.

使用全局命名的流，实现虚拟的日志埋点，只有在需要使用日志的时候，定义日志流的具体实现，那些虚的日志埋点，才会真的有意义。

建立虚的日志埋点

买股票或者买基金，我们经常听到说要低买高卖，但是什么是高，什么是底，究竟用什么衡量比较好？答案是PE，PE代表了估值水平的高低，观看一个股票或者基金的PE变化，就可以得出当前的估值水平是高还是低，决定是否进行交易。

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