芹菜 - 如何从远程机器发送任务？

Question

我们有一台运行芹菜工作者的服务器和一个Redis队列.任务在该服务器上定义.
我需要能够从远程计算机调用这些任务.
我知道它已经完成,send_task但我仍然没有弄清楚怎么办？如何判断send_task队列在哪里？我在哪里通过连接参数(或任何需要的)？我一直在找几个小时,我能找到的就是这个:

from celery.execute import send_task
send_task('tasks.add')

嗯,这意味着我也需要celery在我的呼叫机器上.但我还需要设置什么呢？

Answer 1

这可能是一种方法:创建Celery对象并使用该对象的send_task,该对象可以具有查找代理的配置.

from celery import Celery
celery = Celery()
celery.config_from_object('celeryconfig')
celery.send_task('tasks.add', (2,2))

celeryconfig是一个包含celery配置的文件,还有其他方法在celery对象上设置config.