From 34491829675033e41715648b1e92f339bf2f35d1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 25 八月 2022 17:51:10 +0800
Subject: [PATCH] Changes
---
data_process.py | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/data_process.py b/data_process.py
index 2754d3c..ceaad95 100644
--- a/data_process.py
+++ b/data_process.py
@@ -14,7 +14,7 @@
# 缁熻浠婃棩涔板叆
import tool
-redisManager = redis_manager.RedisManager()
+__redisManager = redis_manager.RedisManager(0)
def _mysql_insert_data(day, code, item, conn):
@@ -94,7 +94,7 @@
# 淇濆瓨L2浜ゆ槗闃熷垪
def saveL2TradeQueueData(code, data):
- redis = redisManager.getRedis()
+ redis = __redisManager.getRedis()
data_str = json.dumps(data)
key = "trade-queue-{}".format(code)
# 淇濆瓨5s鐨勬暟鎹�
@@ -103,7 +103,7 @@
# 鑾峰彇L2浜ゆ槗闃熷垪
def getL2TradeQueueData(code):
- redis = redisManager.getRedis()
+ redis = __redisManager.getRedis()
key = "trade-queue-{}".format(code)
data_str = redis.get(key)
if data_str is None or len(data_str) <= 0:
@@ -160,12 +160,12 @@
def saveClientActive(client_id, host):
if client_id <= 0:
return
- redis = redisManager.getRedis();
+ redis = __redisManager.getRedis();
redis.setex("client-active-{}".format(client_id), 10, host)
def getValidClients():
- redis = redisManager.getRedis();
+ redis = __redisManager.getRedis();
keys = redis.keys("client-active-*")
client_ids = []
for k in keys:
@@ -175,13 +175,13 @@
def getActiveClientIP(client_id):
- redis = redisManager.getRedis();
+ redis = __redisManager.getRedis();
return redis.get("client-active-{}".format(client_id))
# 淇濆瓨閲忚兘
def saveCodeVolumn(datas):
- redis = redisManager.getRedis()
+ redis = __redisManager.getRedis()
for key in datas:
k = "volumn-max-{}".format(key)
redis.setex(k, tool.get_expire(), datas[key]["max_volumn"])
--
Gitblit v1.8.0