diff --git a/run.py b/run.py index 2bc594c736cf22caaa73dbb0598f999f477479a1..6f6065aac69192a06fb60b55aaf6acdc285d79a2 100644 --- a/run.py +++ b/run.py @@ -4,6 +4,7 @@ import os import time import signal import tasks +import vars from flask import session from flask_socketio import SocketIO, join_room @@ -15,8 +16,8 @@ monkey.patch_all(subprocess=True) config_name = os.getenv('FLASK_CONFIG') app = create_app(config_name) -app.config['SECRET_KEY'] = 'vnkdjnfjknfl1232#' -socketio = SocketIO(app, message_queue='amqp://reggie:reggie@ohpc:5672/socketio') +app.config['SECRET_KEY'] = vars.key +socketio = SocketIO(app, message_queue= vars.message_queue) @socketio.on('connect') def socket_connect(): diff --git a/tasks.py b/tasks.py index f596d1d231d5e1dd9ccda5d8614708a1190adf04..e380c9cfdbffe7ca02d9dc36252b83845b6480c8 100644 --- a/tasks.py +++ b/tasks.py @@ -2,14 +2,15 @@ from celery import Celery import time from flask_socketio import SocketIO import subprocess +import vars from gevent import monkey monkey.patch_all(subprocess=True) -broker_url = 'amqp://reggie:reggie@ohpc:5672/' +broker_url = vars.broker_url celery = Celery('flask_user_reg', broker=broker_url) -socketio = SocketIO(message_queue='amqp://reggie:reggie@ohpc:5672/socketio') +socketio = SocketIO(message_queue=vars.message_queue) def send_msg(event, room): print("Post '{}' to room '{}'".format(event,room)) diff --git a/vars.py b/vars.py new file mode 100644 index 0000000000000000000000000000000000000000..9fd2cba6e37c516fe86f97b88c9b6a05ee754fbc --- /dev/null +++ b/vars.py @@ -0,0 +1,3 @@ +Key = 'vnkdjnfjknfl1232' +broker_url = 'amqp://reggie:reggie@ohpc:5672/' +message_queue = broker_url + 'socketio'