Почему установка времени истечения неэффективна в Redis - PullRequest
0 голосов
/ 09 января 2020

Теперь я использую redispipeline, чтобы установить ключ на redis, и установить тайм-аут ключа. После запуска кодов и тайм-аута, а ключи все еще находятся в redis? Кажется, это не работает. X [1] - это dict, например dict ["a"] = b dict ["c"] = d

        redis_pool = redis.ConnectionPool(host = redis_ip, port = redis_port, decode_responses = False)
        redis_connection = redis.StrictRedis(connection_pool = redis_pool)
        redis_pipeline = redis_connection.pipeline(transaction = False)
        sync_count = 0
        for x in iterator:
            key = suffix + x[0]
            #value = str(x['tagid'])+"\t"+x['tag_name']
            value = x[1]
            redis_pipeline.hmset(key,  value)
            redis_pipeline.expire(key,60)
            sync_count += 1
            if (sync_count % 100 == 0):
                result = redis_pipeline.execute()
                print (result)
                time.sleep(0.001)
                break
            if sync_count == 10000:
                break
        redis_pipeline.execute()
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...