Как с помощью Celery и logging в Flask выводить каждую минуту текущее время?

У меня есть такой код как выполнить задачу?


# celery config
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'


# initialize celery app
def get_celery_app_instance(app):
    celery = Celery(
        app.import_name,
        backend=CELERY_BROKER_URL,
        broker=CELERY_BROKER_URL
    )
    celery.conf.update(app.config)

    class ContextTask(celery.Task):
        def __call__(self, *args, **kwargs):
            with app.app_context():
                return self.run(*args, **kwargs)

    celery.Task = ContextTask
    return celery
celery = get_celery_app_instance(app)
from logging import info


# celery tasks
@celery.task
def sending_email_with_celery():
    print(info(msg='This MESSAGE'))
    time.sleep(15)

Ответы (0 шт):