Aioredis pubsub example

import asyncio

import async_timeout

import aioredis

STOPWORD = "STOP"


async def reader(channel: aioredis.client.PubSub):
    while True:
        try:
            async with async_timeout.timeout(1):
                message = await channel.get_message(ignore_subscribe_messages=True)
                if message is not None:
                    print(f"(Reader) Message Received: {message}")
                    if message["data"].decode() == STOPWORD:
                        print("(Reader) STOP")
                        break
                await asyncio.sleep(0.01)
        except asyncio.TimeoutError:
            pass


async def main():
    redis = aioredis.from_url("redis://localhost")
    pubsub = redis.pubsub()
    await pubsub.subscribe("channel:1", "channel:2")

    future = asyncio.create_task(reader(pubsub))

    await redis.publish("channel:1", "Hello")
    await redis.publish("channel:2", "World")
    await redis.publish("channel:1", STOPWORD)

    await future


if __name__ == "__main__":
    asyncio.run(main())

Source: aioredis.readthedocs.io

Similar codes

2 votes169 views2 answers
How to import login required in django
Python Django
6 votes182 views3 answers
Flask cors
Python Flask
12 votes158 views6 answers
How to make a list python
Python
0 vote177 views1 answer
Form action in django
Python Django
1 vote157 views4 answers
Model checkpoint
Python
0 vote140 views1 answer
éliminer le background image python
Python
0 vote144 views1 answer
Abs of complex nos in python
Python
12 votes145 views10 answers
Print in python
Python
15 votes147 views4 answers
Delete function python
Python
10 votes154 views5 answers
Discord.py reply to message
Python