配置Django / Celery将任务发送到不同的代理

作者: 一号位
发布时间: 2024-12-16 03:43:26 (2月前)
转自：

2 条回复

0#
回复此人
Frui tenebris、 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 您可以创建两个芹菜应用程序并将celery.py重命名为celery_app.py以避免自动导入。 </p> <pre> <code> from celery import Celery app1 = Celery('hello', broker='amqp://guest@localhost//') @app1.task def hello1(): return 'hello world from local' </code> </pre> <P> 和 </p> <pre> <code> from celery import Celery app2 = Celery('hello', broker='amqp://guest@remote//') @app2.task def hello2(): return 'hello world from remote' </code> </pre> <P> 对于共享任务： </p> <pre> <code> from celery import shared_task @shared_task def add(x, y): return x + y </code> </pre> <P> 当您运行芹菜工作者节点时： </p> <pre> <code> celery --app=PACKAGE.celery_app:app worker </code> </pre> </DIV>

编辑

登录后才能参与评论