| | |
|---|
| | | from db.redis_manager_delegate import RedisUtils |
|---|
| | | from l2 import l2_data_manager_new |
|---|
| | | from l2.huaxin import huaxin_target_codes_manager |
|---|
| | | from log_module.log import logger_system |
|---|
| | | from third_data import block_info |
|---|
| | | from third_data.history_k_data_util import HistoryKDatasUtils, JueJinApi |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def __set_target_codes(pipe_l2): |
|---|
| | | logger_system.info("启动读取L2订阅代码队列") |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | _datas = huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.pop() |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def __read_sync_task(pipe): |
|---|
| | | logger_system.info("启动读取数据同步服务") |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | if pipe: |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(pipe_server, pipe_l2): |
|---|
| | | print("create TradeApiServer") |
|---|
| | | logger_system.info("create TradeApiServer") |
|---|
| | | # 拉取交易信息 |
|---|
| | | huaxin_trade_data_update.run() |
|---|
| | | # |
|---|
