SimulatedDataHandler¶

class base.SimulatedComponents.SimulatedDataHandler(sim_flag, cn_flag)¶

Methods Summary

解析处理实时传入的数据

Methods Documentation

process_realtime_data(new_data: Dict[str, Dict[str, numpy.ndarray]], callback: Callable[Dict[str, Dict[str, numpy.ndarray]], None])¶

解析处理实时传入的数据

解析新传入的数据, 若其是预先设定需要保存的数据类型(books, trades, candle) 则将其存入`history_data`中, 供之后调用. 完成之后调用`callback`进行处理. 同时使用另一个进程将数据存入数据库中.

Parameters

msg – 一个由JSON转化而来的字典, 包含实时的数据内容
callback – 在处理完实时数据(保存到array中)后调用, 包含新传入的数据 (但不包含历史数据!) 历史数据需要去 :py:attribute:`history_data` 中找