将Celery任务消息发送到RabbitMQ

Question

将Celery任务消息发送到RabbitMQ

pythondjangoredisrabbitmqcelery

3

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

但对于特定情况，我想手动将任务队列添加到rabbitmq中，而不运行Django或celerybeat。

是否有任何简单的Python脚本或shell命令可以做到这一点？

- discover

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- 2ps · Accepted Answer

您可以使用send_task方法将任务排队到任意的Celery代理。但是，您需要知道应用程序名称和代理URL，以便将任务发送到正确的位置。


from celery import Celery

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