I have a django backend which is running Celery for distributed tasks.
I have created a Service bus queue which stores temperature data coming from hundred of frontend devices.
I am running Celer开发者_运维技巧y periodic task every 5 seconds to consume those messages. But the problem is the tasks will be scheduled even if there are no messages in the TEMPERATURE queue.
Is there a way I can set up a Celery worker that can listen to the this queue and operate on it when there is a new task available? Keep in mind this queue is not a tasks queue.
精彩评论