2017-02-06 11 views
0

У меня есть небольшой webapp, написанный на Python с использованием Flask. Некоторые конечные точки, которые у меня есть, требуют длительного времени выполнения (~ 60 с +). Решение состоит в том, чтобы мгновенно возвращать идентификаторы задач, одновременно запуская задачу «Сельдерей» в фоновом режиме.Пропустить журналы Результаты сельдерея

Все работает нормально, как есть. Я перенаправил ведение журнала сельдерея на файл, и он отлично работает. В результате возвращение задачи - это огромная структура данных, которая позже будет обработана и потенциально возвращена конечному пользователю. Однако у меня есть небольшая проблема с протоколированием результатов. Когда сельдерей завершает задачу, он также регистрирует результаты. В моем случае, упомянутая ранее, огромная структура данных. Это делает файл журнала труднее читать и излишне большой.

Возможно ли зарегистрировать только то, что закончилось, состояние и время?

Что-то вроде этого:

[2017-02-06 15:12:01,286: INFO/PoolWorker-6] Task <task_name> succeeded in 60s 

Не так:

[2017-02-06 15:12:01,286: INFO/PoolWorker-6] Task <task_name> succeeded in 60s <very long string, potentially thousands of rows> 

ответ

1

вы можете изменить уровень протоколирования рабочий сельдерея выше затем INFO с:

celery ... --loglevel ERROR 

см больше от doc.