【Redis01】Pipeline

import redis
# run_time 是我自己写的一个装饰器，用来返回被装饰对象的执行时间
from my_python_package.Modifys import run_time


def redis_connection(address: str, port: int, password: str):
    return redis.StrictRedis(address, port, password=password)


@run_time
def execute_multiple_commands_without_pipes(client):
    for i in range(1000):
        client.set(f"string{i}", i)


@run_time
def execute_multiple_commands_with_pipes(client):
    pipeline = client.pipeline()
    for i in range(1000):
        pipeline.set(f"string with pipes{i}", i)
    pipeline.execute()


if __name__ == '__main__':
    client = redis_connection("0.0.0.0", 8100, "password")
    # execute_multiple_commands_without_pipes(client)  # execute_multiple_commands_without_pipes runs at:35.10040497779846 s
    execute_multiple_commands_with_pipes(client)  # execute_multiple_commands_with_pipes runs at:0.17360401153564453 s