From 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 03 八月 2023 18:25:33 +0800
Subject: [PATCH] redis连接池归还
---
gui.py | 18 +++++++++++-------
1 files changed, 11 insertions(+), 7 deletions(-)
diff --git a/gui.py b/gui.py
index c553a7d..43827bb 100644
--- a/gui.py
+++ b/gui.py
@@ -157,15 +157,18 @@
text.delete('1.0', END)
# 楠岃瘉redis
+ redis = redis_manager.RedisManager().getRedis()
try:
- redis = redis_manager.RedisManager().getRedis()
- redis.set("test", "1")
- RedisUtils.delete(redis, "test")
+
+ RedisUtils.set( redis,"test", "1",auto_free=False)
+ RedisUtils.delete(redis, "test", auto_free=False)
text.insert(END, "redis杩炴帴鎴愬姛锛乗n")
except:
error = "redis杩炴帴澶辫触...\n"
text.insert(END, error)
_set_error_color(text, 1, error)
+ finally:
+ redis.connection_pool.disconnect()
# 楠岃瘉mongodb
try:
counts = mysql_data.Mysqldb().select_one("select count(*) from clients")
@@ -220,8 +223,7 @@
# 缁樺埗寮�鐩樺墠鐨勬暟鎹噯澶囨儏鍐�
def __draw_pre_data_check(self, frame):
def refresh_close_price_data():
- redis = redis_manager.RedisManager(0).getRedis()
- count = len(RedisUtils.keys(redis, "price-pre-*"))
+ count = len(RedisUtils.keys(redis_manager.RedisManager(0).getRedis(), "price-pre-*"))
sv_num.set("鑾峰彇鍒版敹鐩樹环鏁伴噺锛歿}".format(count))
def re_get_close_price():
@@ -942,10 +944,10 @@
def export_l2_data_origin(code):
redis = redis_manager.RedisManager(1).getRedis()
- keys = RedisUtils.keys(redis, "big_data-{}-*".format(code))
try:
+ keys = RedisUtils.keys(redis, "big_data-{}-*".format(code), auto_free=False)
for k in keys:
- datas = redis.get(k)
+ datas = redis.get(k, auto_free=False)
datas = json.loads(datas)
_t = k.split("-")[2]
k = time.strftime("%Y_%m_%d_%H_%M_%S_", time.localtime(float(_t) / 1000))
@@ -953,6 +955,8 @@
data_export_util.export_l2_data_origin(code, datas, k)
except Exception as e1:
showerror("瀵煎嚭澶辫触", str(e1))
+ finally:
+ redis.connection_pool.disconnect()
showinfo("鎻愮ず", "瀵煎嚭瀹屾垚")
--
Gitblit v1.8.0