我不确定Python中Celery库中apply_async()
和send_task()
之间的区别,尤其是在使用任务池时。我主要想要的是拥有一个集中的服务器,其中定义了所有任务,并且使用一些Redis队列,其他物理实例能够使用Pools将事件发布/发送到针对不同任务的不同队列,而无需定义每个发布者脚本中可以使用的所有任务列表。
我查阅了文档,实际上并没有找到太多可以回答我问题的内容。
提前感谢!
它们都做相同的事情(请求执行特定任务(。然而,要使apply_async((工作,您需要任务的定义。如果您真的不想仅仅为了触发特定任务而分发代码,send_task()
非常方便(当然,您必须使用相同的序列化,并且知道任务的名称,但如果您是代码库所有者,这不是问题(。