开发者

Allow Celery Worker to consume messages from non task queue

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

上一篇:

下一篇:

精彩评论

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

最新问答

问答排行榜