Как с помощью 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)