python - 如何从另一个程序向 celery 添加任务？

Question

我们在类似守护进程的程序中使用 celery 和 redis 作为代理。我们如何将来自另一个程序的任务添加到这个守护进程？有可能吗？

编辑:

如果描述不够清楚，有两个单独的程序，代码不同，我正在寻找除了从后一个程序导入任务之外的解决方案。

Answer 1

I'm looking for a solution other than importing tasks from the latter program.

你运气不好。 celery 文档提到 worker 和客户需要拥有相同的软件。因此，您的客户端代码需要导入一个 celery 任务，并负责在应用程序控制流中调用它。

引用资料:

• Celery User Guide: Tasks - How it works