提交 d212f661 authored 作者: lc.zhou's avatar lc.zhou

ils-video-recorder:修改rabbitmq心跳

上级 c9835b76
...@@ -7,7 +7,7 @@ from retrying import retry ...@@ -7,7 +7,7 @@ from retrying import retry
def rabbitmq_connect(): def rabbitmq_connect():
config = dynaconf.settings.get('RABBITMQ', {}) config = dynaconf.settings.get('RABBITMQ', {})
amqp_config = dict(user=config.get('USER'), password=config.get('PASSWORD'), host=config.get('HOST'), amqp_config = dict(user=config.get('USER'), password=config.get('PASSWORD'), host=config.get('HOST'),
port=config.get('PORT')) port=config.get('PORT'), heartbeat=0)
if not amqp_config: if not amqp_config:
raise ConnectionError('rabbitmq配置错误') raise ConnectionError('rabbitmq配置错误')
connection = pika.BlockingConnection( connection = pika.BlockingConnection(
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论