N
judge_tp
存储到 lines
break结束死循环
five_list长度 != 0
start_tp = doc的bar_time end_tp
构造 5min K线key列表(five_keys)
遍历docs_list
比较now_tp和当前文档时间戳
返回docs的第一个元素的bar_time
取= judge_tp 的文档(docs)limit * 20条/每次
列表长度==0
docs长度
构造five_list遍历docs
进入死循环
构造文档列表docs_list
five_tp不为None
存five_list
wait_docs长度0
取全部文档(docs)limit * 20条/每次
获取当前时间now_tp创建可存储的文档列表(wait_docs)
0 docs长度 5
添加到wait_docs
列表长度5
进入judge_docs方法
获取five_col最新的时间戳(five_tp)
5 * 60 *1000
拷贝一份文件列表(docs_list)为docs设置时间间隔interval将docs第一个元素的bar_time设置为起始时间(start_tp)start_tp + interval设置为结束时间(end_tp)
使用insert_many将lines的数据一次插入对应的集合
docs长度 = 0
获取five_key对应的集合(five_col)
Y
从docs中删除five_list里的元素
返回docs_list最后一个元素的bar_time + 1
遍历
取five_tp 的文档(docs)limit * 20条/每次
构造one_key创建one_col
