推荐学习书目 Learn Python the Hard Way Python Sites PyPI - Python Package Index http://diveintopython.org/toc/index.html Pocoo 值得关注的项目 PyPy Celery Jinja2 Read the Docs gevent pyenv virtualenv Stackless Python Beautiful Soup 结巴中文分词 Green Unicorn Sentry Shovel Pyflakes pytest Python 编程 pep8 Checker Styles PEP 8 Google Python Style Guide Code Style from The Hitchhiker's Guide
这是一个创建于 2141 天前的主题，其中的信息可能已经有所发展或是发生改变。
broker_url = 'amqp://guest:guest@localhost:5672/my_vhost' task_routes = { 'project.task.create_order': { 'queue': 'succeed' }, } imports = [ 'project.task', ] @app.task def hello(msg): sleep(2) print('hello') @app.task def create_order(data): sleep(2) print('create_order') 我的设想是 create_order 会自动处理 succeed 里面的消息, 而 hello 是需要的时候手动调用
以下面的命令启动后:
celery -A project.main worker -l info -Q succeed -P eventlet -E
create_order 正常工作, 但调用 hello 没反应
celery -A project.main worker -l info -P eventlet -E
去掉 -Q succeed 的话就相反了, hello 可以正常调用, 但 create_order 就不工作...
我记得我以前试过是可以同时工作的?
 | 1 ifoolish 2019-12-08 18:55:19 +08:00 问题很明显了。你的配置文件中 create_order 指定了队列 succeed，你运行 worker 的参数 -Q succeed 也指定了这是 处理 succeed 队列的 worker，那当然只会执行 create_order 啊，想要 hello 也会得到执行，你再多开一个处理默认队列的 worker 进程就行了，也就是不加 -Q 参数 |
| 2 ifoolish 2019-12-08 18:59:34 +08:00 或者你只想开一个 worker 进程的话，-Q 参数加上默认队列的名字，即-Q succeed,celery。仔细看看文档吧 |
 | 3 aoscici2000 OP @ifoolish 谢谢, 确实如此, celery 貌似是自动生成了队列, 没留意到 |
Select Language