| 29 | |
| 30 | @timer |
| 31 | async def run(client): |
| 32 | data_str = "a" * size |
| 33 | data_int = int("1" * size) |
| 34 | |
| 35 | for i in range(count): |
| 36 | with client.pipeline() as pipe: |
| 37 | await ( |
| 38 | pipe.set(f"bench:str_{i}", data_str) |
| 39 | .set(f"bench:int_{i}", data_int) |
| 40 | .get(f"bench:str_{i}") |
| 41 | .get(f"bench:int_{i}") |
| 42 | .hset("bench:hset", str(i), data_str) |
| 43 | .hget("bench:hset", str(i)) |
| 44 | .incr("bench:incr") |
| 45 | .lpush("bench:lpush", data_int) |
| 46 | .lrange("bench:lpush", 0, 300) |
| 47 | .lpop("bench:lpush") |
| 48 | .execute() |
| 49 | ) |
| 50 | |
| 51 | |
| 52 | async def main(loop): |