Разрешить Celery Worker потреблять сообщения из очереди, не относящейся к задаче
У меня есть django backend, который использует Celery для распределенных задач.
Я создал очередь шины обслуживания, которая хранит данные о температуре, поступающие от сотни внешних устройств.
Я запускаю периодическую задачу Celery каждые 5 секунд для потребления этих сообщений. Но проблема в том, что задачи будут запланированы, даже если в очереди TEMPERATURE нет сообщений.
Есть ли способ настроить Celery worker, который будет прослушивать эту очередь и работать с ней, когда будет доступна новая задача? Следует помнить, что эта очередь не является очередью задач.