# pip3 install redis

import redis
from concurrent.futures import ThreadPoolExecutor

res = None


def connect():
    res = redis.StrictRedis(host='172.22.0.8', port=6379, db=0, password='pc8DphhaXwTe2jyv')
    return res


def scan():
    # 创建一个包含100条线程的线程池
    thread = ThreadPoolExecutor(max_workers=100)
    cursor = 0
    while True:
        tup = res.scan(cursor=cursor, match='peko:seize_treasure:user_info:*', count=1000)
        k = tup[0]
        v = tup[1]
        if isinstance(k, int):
            cursor = k
        if isinstance(v, list):
            # 启动线程执行
            try:
                handle_keys(v)
            except Exception as e:
                print("thread submit error.", e)
        if cursor == 0:
            break
    # 关闭线程池
    thread.shutdown()


def handle_keys(keys):
    try:
        for k in keys:
            key = k.decode('utf-8')
            print(key)
            # res.delete(key)
    except Exception as e:
        print("handle_keys error.", e)


if __name__ == '__main__':
    res = connect()
    if res is None:
        print("redis connect is error.")
    else:
        print("redis connect is success.")
        scan()