redis批量提交数据

Administrator

2023-08-07 e0ca7b43c17ebe25e718d5ca229c989f48340015

 l2/l2_data_manager.py

@@ -9,6 +9,7 @@
from log_module.log import logger_l2_trade_buy
from utils.tool import CodeDataCacheUtil

_db = 1
_redisManager = redis_manager.RedisManager(1)


@@ -42,7 +43,7 @@
    @staticmethod
    def delete_buy_point(code):
        CodeDataCacheUtil.clear_cache(TradePointManager.__buy_compute_index_info_cache, code)
        RedisUtils.delete_async(TradePointManager.__get_redis(), "buy_compute_index_info-{}".format(code))
        RedisUtils.delete_async(_db, "buy_compute_index_info-{}".format(code))

    # 获取买入点信息
    # 返回数据为：买入点 累计纯买额 已经计算的数据索引
@@ -86,7 +87,7 @@
                     volume_rate)
        CodeDataCacheUtil.set_cache(TradePointManager.__buy_compute_index_info_cache, code, data_)
        RedisUtils.setex_async(
            TradePointManager.__get_redis(), _key, expire,
            _db, _key, expire,
            json.dumps(data_))

    # 获取撤买入开始计算的信息
@@ -110,7 +111,7 @@
    # 删除买撤点数据
    @classmethod
    def delete_buy_cancel_point(cls, code):
        RedisUtils.delete_async(TradePointManager.__get_redis(), "buy_cancel_single_pos-{}".format(code))
        RedisUtils.delete_async(_db, "buy_cancel_single_pos-{}".format(code))

    # 设置买撤纯买额
    @classmethod
@@ -131,7 +132,7 @@

    @classmethod
    def delete_compute_info_for_cancel_buy(cls, code):
        RedisUtils.delete_async(TradePointManager.__get_redis(), "compute_info_for_cancel_buy-{}".format(code))
        RedisUtils.delete_async(_db, "compute_info_for_cancel_buy-{}".format(code))

    # 从买入信号开始设置涨停买与涨停撤的单数
    @classmethod
@@ -153,7 +154,7 @@

    @classmethod
    def delete_count_info_for_cancel_buy(cls, code):
        RedisUtils.delete_async(TradePointManager.__get_redis(), "count_info_for_cancel_buy-{}".format(code))
        RedisUtils.delete_async(_db, "count_info_for_cancel_buy-{}".format(code))


# 清除l2数据