from_coroutine 和from_future

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

需求

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

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

1. 使用apscheduler tornad模块,启动scheduler

一般使用流的业务,数据都会连绵不绝比较多,我们一般不会做存储,算完即走,但是有时需要使用流刚刚用过的的一些数据,这时就可以使用流的缓存机制

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

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

建立虚的日志埋点