perf: 修改 redis conn

This commit is contained in:
ibuler
2022-03-08 18:47:39 +08:00
committed by 老广
parent 1cca9c10fb
commit 9492518773
2 changed files with 5 additions and 5 deletions

View File

@@ -55,9 +55,9 @@ class Subscription:
_next(item)
except Exception as e:
error(msg, item)
logger.error('Subscribe handler handle msg error: ', e)
logger.error('Subscribe handler handle msg error: {}'.format(e))
except Exception as e:
logger.error('Consume msg error: ', e)
logger.error('Consume msg error: {}'.format(e))
try:
complete()
@@ -100,4 +100,4 @@ class RedisPubSub:
self.redis.publish(self.ch, data_json)
return True