diff --git a/src/app.py b/src/app.py new file mode 100644 index 0000000000000000000000000000000000000000..e15da7071a128ae1989c8083b982a5206863279a --- /dev/null +++ b/src/app.py @@ -0,0 +1,13 @@ +import sys +import subprocess +import covid19 +import covid19_worker +from covid19 import app +from covid19.blueprints.application.application_workers import run_app + +# --------------------------------------------------------------------------------- +# MAIN +# --------------------------------------------------------------------------------- + +if __name__ == '__main__': + run_app(app) diff --git a/src/covid19/blueprints/application/application_workers.py b/src/covid19/blueprints/application/application_workers.py index 0c8964d0ce63be794d0b09b982b3e71c769bf936..9764eefc2038c7e46f1ecb26985b2416e83d1fde 100644 --- a/src/covid19/blueprints/application/application_workers.py +++ b/src/covid19/blueprints/application/application_workers.py @@ -1,7 +1,7 @@ import sys import subprocess from covid19 import app -from database import create_celery +from database import create_celery, run_run_with_debug, port def run_mq(my_app, my_celery): @@ -20,4 +20,29 @@ def run_mq(my_app, my_celery): my_celery.start(args) +def run_app(my_app): + if sys.platform != 'linux': + my_app.logger.info("-------------------------------------------------------------") + my_app.logger.info("# start REDIS-Server #") + my_app.logger.info("-------------------------------------------------------------") + redis_cmd = ['redis-server'] + subprocess.Popen(redis_cmd, shell=True) + my_app.logger.info(" ") + my_app.logger.info("#############################################################") + my_app.logger.info("# Covid19 Data - WORKER #") + my_app.logger.info("#############################################################") + my_app.logger.info(" ") + celery_cmd = ['celery', 'worker', '-l', 'INFO'] + subprocess.Popen(celery_cmd, shell=True) + my_app.logger.info(" ") + my_app.logger.info("#############################################################") + my_app.logger.info("# Covid19 Data - WEB #") + my_app.logger.info("#############################################################") + my_app.logger.info(" ") + my_app.run( + debug=run_run_with_debug, + port=port + ) + + celery = create_celery(app)