| | |
| | | RedisUtils.setex(redis, "volumn_max60-{}".format(code), tool.get_expire(), json.dumps((max60, max60_day)), auto_free=False) |
| | | RedisUtils.setex(redis, "volumn_yes-{}".format(code), tool.get_expire(), yesterday, auto_free=False) |
| | | finally: |
| | | redis.connection_pool.disconnect() |
| | | RedisUtils.realse(redis) |
| | | |
| | | |
| | | # 获取历史量 |
| | |
| | | yesterday = RedisUtils.get(redis, "volumn_yes-{}".format(code), auto_free=False) |
| | | return max60, yesterday |
| | | finally: |
| | | redis.connection_pool.disconnect() |
| | | RedisUtils.realse(redis) |
| | | |
| | | |
| | | __today_volumn_cache = {} |
| | |
| | | code = k.split("-")[1] |
| | | global_util.yesterday_volumn[code] = RedisUtils.get(redis, k, auto_free=False) |
| | | finally: |
| | | redis.connection_pool.disconnect() |
| | | RedisUtils.realse(redis) |
| | | |
| | | |
| | | if __name__ == "__main__": |