A generic interface wrapping multiple backends to provide a consistent pubsub API.
pip install aio-pubsub
# for redis backend
pip install aio-pubsub[aioredis]
# for postgresql backend
pip install aio-pubsub[aiopg]To use it, you need to implement your pubsub implementation from interfaces or use backends from aio_pubsub.backends package
import asyncio
from aio_pubsub.backends.memory import MemoryPubSub
pubsub = MemoryPubSub()
async def sender():
"""Publish a new message each second"""
counter = 0
while True:
await pubsub.publish("a_chan", "hello world %s !" % counter)
await asyncio.sleep(1)
counter += 1
async def receiver():
"""Print all message received from channel"""
subscriber = await pubsub.subscribe("a_chan")
async for message in subscriber:
print("Received message: '%s'" % message)
loop = asyncio.get_event_loop()
loop.run_until_complete(
asyncio.gather(sender(), receiver())
)
loop.close()Disclaimer: I would not advise you to use this backend, because it is shown only for testing purposes. Better develop your own implementation.
- memory
- redis
- postgresql
- mongodb