Skip to content

Instantly share code, notes, and snippets.

@wh13371

wh13371/redis_stream_consumer.py

Created December 22, 2020 13:49
Show Gist options
  • Save wh13371/0da973d544f7d394e179a413f5771a5a to your computer and use it in GitHub Desktop.
Save wh13371/0da973d544f7d394e179a413f5771a5a to your computer and use it in GitHub Desktop.
Download ZIP
Raw
redis_stream_consumer.py
def start_redis_consumer():
dd("Starting Redis Consumer")
while True:
events = r.xread({REDIS_STREAM: '$'}, block=0, count=None)
for _, data in events:
stream = _
_redisid = data[0][0]
_redisdata = data[0][1]
# do something with "stream" , "_redisid" and "_redisdata"
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment