Как запустить Celery Beat на Flask - PullRequest
Новая
       47

Как запустить Celery Beat на Flask

0 голосов
/ 07 февраля 2020

В настоящее время у меня есть flask код, который выглядит следующим образом app.py 

from services.celery_maker import make_celery
from flask import Flask
from datetime import timedelta

template_dir = os.path.abspath('./build/')
app = Flask(__name__, template_folder=template_dir, static_folder=os.path.abspath("./build/static"))

app.config['ERROR_404_HELP'] = False
app.config['SECRET_KEY'] = config.get("DEFAULT", "SECRET_KEY")
app.config['PERMANENT_SESSION_LIFETIME'] = timedelta(minutes=5)

app.config.update(
    CELERY_BROKER_URL='redis://127.0.0.1:6379/0',
    CELERY_RESULT_BACKEND='redis://127.0.0.1:6379/0',
)

app.config['CELERYBEAT_SCHEDULE'] = {
    # Executes every minute
    'periodic_task-every-minute': {
        'task': 'periodic_task',
        'schedule': timedelta(seconds=30)
    }
}



@app.route('/')
def view():
    return "Hello, Flask is up and running!"

@celery.task(name ="periodic_task")
def periodic_task():
    print('Hi! from periodic_task')
    logger.info("Hello! from periodic task")

if __name__ == "__main__":
    app.run(debug = True)

У меня есть производитель сельдерея в другом файле, чтобы остановить относительные ошибки импорта

services.celery_maker.py 

from celery import Celery


def make_celery(app_name=__name__):
    backend = "redis://localhost:6379/0"
    broker = backend.replace("0", "1")

    return Celery(app_name, backend=backend, broker=broker)


celery = make_celery()

работник сельдерея видит мою задачу, но она не запускается вообще, я не знаю, что происходит

1 Ответ

0 голосов
/ 05 марта 2020

для периодических c задач в сельдерее, вам также необходимо использовать ритм сельдерея, биты будут планировать задачи, и рабочие будут выполнять задачу, короче говоря, вместе с рабочим вам также нужно запустить ритм сельдерея 

celery beat -A <path_to_worker_created_under_celery_app> -l info

например. в вашем случае celery beat -A services.celery_maker.celery -l info

...