redis连接池归还

Administrator

2023-08-04 c3429ad2482280083c8399412e6b2f3f6144d3b7

 trade/trade_manager.py

@@ -165,7 +165,7 @@
                    codes.append(key.replace("trade-state-", ''))
        return codes
    finally:
        redis.connection_pool.disconnect()
        RedisUtils.realse(redis)


def get_codes_by_trade_states(states):
@@ -179,7 +179,7 @@
                    codes.append(key.replace("trade-state-", ''))
        return codes
    finally:
        redis.connection_pool.disconnect()
        RedisUtils.realse(redis)


# 设置交易账户的可用金额
@@ -281,7 +281,7 @@
        else:
            return json.loads(result), time_str
    finally:
        redis.connection_pool.disconnect()
        RedisUtils.realse(redis)


# 开始交易
@@ -535,7 +535,7 @@
            # if (k.find("l2-") is None or k.find("l2-") < 0) and (k.find("big_data-") is None or k.find("big_data-") < 0):
            RedisUtils.delete(redis_l2, k, auto_free=False)
    finally:
        redis_l2.connection_pool.disconnect()
        RedisUtils.realse(redis_l2)

    RedisUtils.delete(redis_manager.RedisManager(2).getRedis(), "trade-state-{}".format(code))

@@ -550,7 +550,7 @@

            RedisUtils.delete(redis_info, k, auto_free=False)
    finally:
        redis_info.connection_pool.disconnect()
        RedisUtils.realse(redis_info)


def __clear_big_data():
@@ -560,7 +560,7 @@
        for k in keys:
            RedisUtils.delete(redis_l2, k, auto_free=False)
    finally:
        redis_l2.connection_pool.disconnect()
        RedisUtils.realse(redis_l2)


if __name__ == "__main__":