我有2个使用Celery连接到同一代理的不同Python应用程序。
服务器A拥有我所有的@tasks,但是我需要从服务器B执行此任务。我无法执行标准导入任务,因为它在服务器B上不存在。
如何在服务器B的Celery中运行仅在服务器A上存在的任务?
IE
服务器B:
from tasksFromSeverA import add
add.delay(4, 4)
Celery中是否有某些东西可以让您发送信号,要求将一个名为“添加”的任务发送给经纪人?
据我所知,您无法在“服务器B”中未实现的“服务器B”中执行任务。
您可以做的是在“服务器B”中的“服务器A”中执行任务。您可以使用send_task函数来实现此目的,如以下链接中所述:
http://celery.readthedocs.org/en/latest/faq.html#can-i-call-a-task-by-name
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句