| 12345678910111213 |
- import redis
- import time
- r = redis.Redis(host='db.ptt.cx', port=6379, db=1)
- p = r.pubsub(ignore_subscribe_messages=True)
- p.subscribe('q_hhh_seo')
- while True:
- message = p.get_message()
- if message:
- print(message['data'].decode('utf-8'))
- time.sleep(0.001) # be nice to the system :)
|
