开发者

Allow Celery Worker to consume messages from non task queue

开发者 https://www.devze.com 2022-12-07 17:48 出处:网络
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 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.

0

精彩评论

暂无评论...
验证码 换一张
取 消