Skip to content

Instantly share code, notes, and snippets.

@guyroyse

guyroyse/read_from_queue.py

Created June 25, 2020 19:07
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save guyroyse/3369111928307a1a835ec70c4bb8525e to your computer and use it in GitHub Desktop.
Save guyroyse/3369111928307a1a835ec70c4bb8525e to your computer and use it in GitHub Desktop.
Download ZIP
Raw
read_from_queue.py
import asyncio
import aioredis
from pprint import pp
async def main():
redis = await aioredis.create_redis('redis://:foobared@localhost:6379/0', encoding='utf-8')
while True:
sighting = await redis.blpop('bigfoot:sightings:received')
pp(sighting)
asyncio.run(main())
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment