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

0 vote153 views1 answer
Python manually trigger exception
Python
0 vote157 views2 answers
%Y-%m-%dT%H:%M:%SZ convert to date time object
Python
2 votes154 views1 answer
Argparse example python pyimagesearch
Python
-1 vote150 views1 answer
How do you split a list into evenly sized chunks?
Python
0 vote179 views1 answer
Django.core.exceptions.ImproperlyConfigured: Application labels aren't unique, duplicates: auth
Python Django
38 votes146 views2 answers
Python check if path does not exist
Python
0 vote173 views2 answers
Examples of function decorators in Python
Python
0 vote173 views1 answer
Python tkinter get image size
Python
3 votes254 views1 answer
Mouse bottom in pygame
Python
0 vote155 views1 answer
Pandas_datareader
Python