芹菜服务器不可能立即响应消息吗?
Is it just not possible to have a celery server respond immediately to a message?
我有几个 celery 服务器,每个服务器有一个工人。工人们正忙于执行长时间(8 小时;我无法将其拆分)的任务。我希望能够告诉每个服务器立即做某事;但看起来这真的不可能 - 我相信广播会在当前任务完成后执行任务,我相信?
这可以通过一个特殊的队列来实现,比如说,分配 1 个工作进程。默认情况下,除非您需要立即完成某件事,否则不会进入此队列。
celery.bin.multi reference page 展示了如何做到这一点。
我有几个 celery 服务器,每个服务器有一个工人。工人们正忙于执行长时间(8 小时;我无法将其拆分)的任务。我希望能够告诉每个服务器立即做某事;但看起来这真的不可能 - 我相信广播会在当前任务完成后执行任务,我相信?
这可以通过一个特殊的队列来实现,比如说,分配 1 个工作进程。默认情况下,除非您需要立即完成某件事,否则不会进入此队列。
celery.bin.multi reference page 展示了如何做到这一点。