| Server IP : 109.234.164.53 / Your IP : 216.73.216.136 Web Server : Apache System : Linux cervelle.o2switch.net 4.18.0-553.32.1.lve.el8.x86_64 #1 SMP Thu Dec 19 13:14:03 UTC 2024 x86_64 User : computer3 ( 1098) PHP Version : 7.1.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python35/share/doc/alt-python35-aioredis/examples/ |
Upload File : |
import asyncio
import aioredis
async def main():
redis = await aioredis.create_redis(
'redis://localhost')
# No pipelining;
async def wait_each_command():
val = await redis.get('foo') # wait until `val` is available
cnt = await redis.incr('bar') # wait until `cnt` is available
return val, cnt
# Sending multiple commands and then gathering results
async def pipelined():
fut1 = redis.get('foo') # issue command and return future
fut2 = redis.incr('bar') # issue command and return future
# block until results are available
val, cnt = await asyncio.gather(fut1, fut2)
return val, cnt
# Explicit pipeline
async def explicit_pipeline():
pipe = redis.pipeline()
fut1 = pipe.get('foo')
fut2 = pipe.incr('bar')
result = await pipe.execute()
val, cnt = await asyncio.gather(fut1, fut2)
assert result == [val, cnt]
return val, cnt
res = await wait_each_command()
print(res)
res = await pipelined()
print(res)
res = await explicit_pipeline()
print(res)
redis.close()
await redis.wait_closed()
if __name__ == '__main__':
loop = asyncio.get_event_loop()
loop.run_until_complete(main())