python 一个简短的脚本,用Python探索Redis pubsub函数
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python 一个简短的脚本,用Python探索Redis pubsub函数相关的知识,希望对你有一定的参考价值。
import redis
import threading
class Listener(threading.Thread):
def __init__(self, r, channels):
threading.Thread.__init__(self)
self.redis = r
self.pubsub = self.redis.pubsub()
self.pubsub.subscribe(channels)
def work(self, item):
print item['channel'], ":", item['data']
def run(self):
for item in self.pubsub.listen():
if item['data'] == "KILL":
self.pubsub.unsubscribe()
print self, "unsubscribed and finished"
break
else:
self.work(item)
if __name__ == "__main__":
r = redis.Redis()
client = Listener(r, ['test'])
client.start()
r.publish('test', 'this will reach the listener')
r.publish('fail', 'this will not')
r.publish('test', 'KILL')
以上是关于python 一个简短的脚本,用Python探索Redis pubsub函数的主要内容,如果未能解决你的问题,请参考以下文章
python 刷新HTML文本区域的简短脚本
你将如何优化这个简短但非常慢的 Python 循环?
python爬虫——爬取小说 | 探索白子画和花千骨的爱恨情仇
R,Python,Scala 和 Java,到底该使用哪一种大数据编程语言
怎样用QtCreator编辑运行python脚本
基于 Arduino 的加速度计鼠标的 Python 脚本不起作用