public
/
ottertune
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix rabbitmq hostname

This commit is contained in:
yangdsh 2020-04-21 17:59:21 +00:00 committed by Dana Van Aken
parent d47b09b0c0
commit efcc2ee74b
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/website/website/utils.py
View File

@ -26,7 +26,7 @@ from django_db_logger.models import StatusLog
from djcelery.models import TaskMeta from djcelery.models import TaskMeta
from .models import DBMSCatalog, KnobCatalog, Result, Session, SessionKnob from .models import DBMSCatalog, KnobCatalog, Result, Session, SessionKnob
from .settings import constants from .settings import common
from .types import LabelStyleType, VarType from .types import LabelStyleType, VarType
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
@ -568,12 +568,14 @@ def check_and_run_celery():
if 'pong' in celery_status: if 'pong' in celery_status:
return 'celery is running' return 'celery is running'
rabbitmq_status = os.popen('telnet localhost 5672').read() rabbitmq_url = common.BROKER_URL.split('@')[-1]
hostname = rabbitmq_url.split(':')[0]
port = rabbitmq_url.split(':')[1].split('/')[0]
rabbitmq_status = os.popen('telnet {} {}'.format(hostname, port)).read()
if 'Connected' in rabbitmq_status: if 'Connected' in rabbitmq_status:
LOG.info('Rabbitmq is running.') LOG.info('Rabbitmq is running.')
else: else:
LOG.warning('Rabbitmq is not running.') LOG.warning('Rabbitmq is not running.')
return 'Rabbitmq is not running.'
retries = 0 retries = 0
while retries < 5: while retries < 5: