From e8ea6340db725a3b36a78e090fc6f97a90900264 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 14:06:29 +0800
Subject: [PATCH] redis批量提交数据
---
l2/l2_data_manager.py | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/l2/l2_data_manager.py b/l2/l2_data_manager.py
index cdb8a7b..57d9e61 100644
--- a/l2/l2_data_manager.py
+++ b/l2/l2_data_manager.py
@@ -42,7 +42,7 @@
@staticmethod
def delete_buy_point(code):
CodeDataCacheUtil.clear_cache(TradePointManager.__buy_compute_index_info_cache, code)
- RedisUtils.delete(TradePointManager.__get_redis(), "buy_compute_index_info-{}".format(code))
+ RedisUtils.delete_async(TradePointManager.__get_redis(), "buy_compute_index_info-{}".format(code))
# 鑾峰彇涔板叆鐐逛俊鎭�
# 杩斿洖鏁版嵁涓猴細涔板叆鐐� 绱绾拱棰� 宸茬粡璁＄畻鐨勬暟鎹储寮�
@@ -110,7 +110,7 @@
# 鍒犻櫎涔版挙鐐规暟鎹�
@classmethod
def delete_buy_cancel_point(cls, code):
- RedisUtils.delete(TradePointManager.__get_redis(), "buy_cancel_single_pos-{}".format(code))
+ RedisUtils.delete_async(TradePointManager.__get_redis(), "buy_cancel_single_pos-{}".format(code))
# 璁剧疆涔版挙绾拱棰�
@classmethod
@@ -131,7 +131,7 @@
@classmethod
def delete_compute_info_for_cancel_buy(cls, code):
- RedisUtils.delete(TradePointManager.__get_redis(), "compute_info_for_cancel_buy-{}".format(code))
+ RedisUtils.delete_async(TradePointManager.__get_redis(), "compute_info_for_cancel_buy-{}".format(code))
# 浠庝拱鍏ヤ俊鍙峰紑濮嬭缃定鍋滀拱涓庢定鍋滄挙鐨勫崟鏁�
@classmethod
@@ -153,7 +153,7 @@
@classmethod
def delete_count_info_for_cancel_buy(cls, code):
- RedisUtils.delete(TradePointManager.__get_redis(), "count_info_for_cancel_buy-{}".format(code))
+ RedisUtils.delete_async(TradePointManager.__get_redis(), "count_info_for_cancel_buy-{}".format(code))
# 娓呴櫎l2鏁版嵁
--
Gitblit v1.8.0