From fb47d36048e94b9a506d5c153e3dd19a01e37df1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 30 十月 2023 16:30:27 +0800
Subject: [PATCH] bug修复
---
third_data/kpl_data_manager.py | 11 +++++++----
1 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index 44078a6..d90a373 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -1,4 +1,5 @@
import json
+import logging
import os
import threading
import time
@@ -327,11 +328,13 @@
while True:
if tool.is_trade_time():
try:
- results = kpl_api.daBanList(kpl_api.DABAN_TYPE_LIMIT_UP)
+ results = kpl_api.getLimitUpInfo()
result = json.loads(results)
+ start_time = time.time()
__upload_data("limit_up", result)
+ logger_kpl_limit_up_reason_change.info("涓婁紶鑰楁椂锛歿}", time.time() - start_time)
except Exception as e:
- pass
+ logging.exception(e)
time.sleep(3)
def get_bidding_money():
@@ -370,8 +373,8 @@
threading.Thread(target=get_limit_up, daemon=True).start()
threading.Thread(target=get_bidding_money, daemon=True).start()
- threading.Thread(target=get_market_industry, daemon=True).start()
- threading.Thread(target=get_market_jingxuan, daemon=True).start()
+ # threading.Thread(target=get_market_industry, daemon=True).start()
+ # threading.Thread(target=get_market_jingxuan, daemon=True).start()
if __name__ == "__main__":
--
Gitblit v1.8.0