向rabbitmq.发送芹菜任务消息

Question

我通常在Django中使用芹菜，并在Djano中运行共享任务。

但对于特定的情况，我想在不运行Django或celeybeat的情况下手动将任务队列添加到rabbitmq。

有没有简单的python脚本或shell cmd可以做到这一点？

Answer 1

您可以使用send_task方法将任务排队到任意的芹菜代理。但是，你必须知道应用程序名称和代理url，这样你才能将任务发送到正确的位置。

from celery import Celery
app = Celery('app_name', broker='pyamqp://guest@localhost//')
app.send_task('namespace.my_task', kwargs={
'arg1': 'value1',
'arg2': 'value2',
})