send_task() 和 apply_async() 之间的区别

Question

我不确定 Python 中 Celery 库中 apply_async() 和 send_task() 之间的区别，特别是在使用任务池时。 我主要寻找的是拥有一个集中式服务器，其中定义了所有任务，并使用一些 Redis 队列，其他物理实例能够 publish/send 使用池将事件发送到针对不同任务的不同队列，而无需需要在每个发布者脚本中定义所有任务列表才能使用。

我查看了文档，但实际上并没有找到多少可以回答我的问题。

提前致谢！

Answer 1

他们都做同样的事情（请求执行特定任务）。但是，要使 apply_async() 工作，您需要任务的定义。 send_task() 在你真的不想仅仅为了触发特定任务而分发代码的情况下非常方便（当然，你必须使用相同的序列化，并且知道任务的名称，但如果你是代码库所有者，这不是问题）。