在 flask 项目中,单独开一个进程来订阅第三方 redis 的 channel,代码如下
r = redis.Redis(connection_pool=pool)
p = r.pubsub()
p.subscribe([channel])
for sub in p.listen():
print(sub)
在项目启动之后该监听服务正常,但是在十几分钟之后该服务不再工作,有老哥知道原因吗?是不是有个配置能够保证该 redis 连接为长连接。
1
xpresslink 2018-11-19 16:41:11 +08:00
再弄个线程,用 timer 每 5 分钟 keepalive 一下。:-)
|