blob: f38249d7cb166d29f7a967addaa1e91bbc7c9db9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
from configure import REDIS_CHANNEL
import redis # install redis on Ubuntu using this command: sudo apt install python3-redis
import json
import os
redis_password = os.getenv('REDIS_PASSWORD', '123456')
redis_host = os.getenv('REDIS_HOST', '127.0.0.1')
r = redis.Redis(host=redis_host, port=6379, password=redis_password, db=0)
pubsub = r.pubsub(ignore_subscribe_messages=True)
pubsub.subscribe(REDIS_CHANNEL)
for message in pubsub.listen():
quant_data = json.loads(message['data'])
filename = quant_data['filename']
print('[test_redis_subscribe.py] %s - %s.' % (filename, quant_data))
|
