Привет, коллеги.
Использую celery в связке с Django. Вот конфиг сервиса:
[Unit]
Description=celery daemon
After=network.target
[Service]
User=reviews
Group=reviews
WorkingDirectory=/opt/xxx/web/
Environment="PATH=/opt/xxx/bin"
ExecStart=/opt/xxx/bin/celery worker -A AppReviews
[Install]
WantedBy=multi-user.target
CELERY_BROKER_URL = 'redis://:pass@host/0'
CELERY_RESULT_BACKEND = 'redis://:pass@host/1'
CELERY_TASK_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json']
Схема такая: при сохранении объекта в БД срабатывает сигнал и при определенных условиях создается таск для Celery. Оно работает, но периодически задачи перестают создаваться (мониторю через flower). После рестарта сервиса все начинает работать.
Собственно, как это диагностировать и как починить?
P.S. Работает оно через redis, он живее всех живых.