Django Celery Beat не отправлял сообщение брокеру SQS (Django, SQS, DatabaseScheduler)
У меня есть 2 экземпляра t2 на AWS, один для beat, другой для worker.
Beat (t2.micro): celery -A iso_backend beat -l info --scheduler django
Worker (t2.small): celery -A iso_backend worker -l info --scheduler django
Я использую таблицу djang_celery_beat_clockedschedule для планирования множества длительных заданий.
Много clocked имеет_много заданий, так например: в 08:20:00 утра, Beat должен вызвать 100 сообщений в очередь SQS одновременно, проблема в том, что он вызывает только несколько, иногда 1/2, иногда 1/3 количество заданий
Scheduler: Sending due task...
На самом деле, этот вопрос действительно сложный, и я не могу понять первопричину.
Кто-нибудь сталкивался с этим раньше и имеет какие-либо решения, чтобы помочь мне?
Большое спасибо!