redis批量修改过期时间

2019-11-01  本文已影响0人  louislivi

利用python多线程以及文件读行高效率实现redis过期时间批量快速修改。

  • 更新300万数据预计耗时在20分钟。
redis-cli -h 127.0.0.1 -a password -n 0 keys "*" > keys.txt
import redis
from concurrent.futures import ThreadPoolExecutor

pool = redis.ConnectionPool(host="127.0.0.1 ", password="password",
                            port=6379, db=0)
r = redis.StrictRedis(connection_pool=pool)
executor = ThreadPoolExecutor(max_workers=100)


def change_exp(line):
    line = line.strip('\n')
    r.expire(line, 2592000)
    return line


result = []
count = 0
with open("keys.txt") as f:
    tasks = [executor.submit(change_exp, line) for line in f.readlines()]
    for task in tasks:
        if task.done():
            result.append(task.result())

python ./test.py
上一篇 下一篇

猜你喜欢

热点阅读