| | |
|---|
| | | if data.get("type") == 'set_target_codes': |
|---|
| | | # [(代码, 时间戳, 价格, 总交易量, 总交易额, 买5, 卖5)] |
|---|
| | | market_data_list = data["data"]["data"] |
|---|
| | | strategy_manager.low_suction_strtegy.add_ticks(market_data_list) |
|---|
| | | if strategy_manager.low_suction_strtegy: |
|---|
| | | strategy_manager.low_suction_strtegy.add_ticks(market_data_list) |
|---|
| | | RealTimeEnvInfo().ticks = (tool.get_now_time_str(), len(market_data_list)) |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | |
|---|
| | | threading.Thread(target=test, daemon=True).start() |
|---|
| | | # test() |
|---|
| | | |
|---|
| | | # 初始化数据 |
|---|
| | | strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str()) |
|---|
| | | |
|---|
| | | # -------启动L2 market订阅------ |
|---|
| | | __run_l2_market_subscript() |
|---|
| | | print("启动完成") |
|---|
