擅长:python、mysql、java
<p>默认情况下,所有内容都进入一个名为<code>celery</code>的默认队列(如果未指定队列,这就是<code>celery worker</code>将处理的内容)</p>
<p>假设你在<code>django_project_root/myapp/tasks.py</code>中有你的<code>do_work</code>任务函数。</p>
<p>您可以将<code>do_work</code>任务配置为位于它自己的队列中,如下所示:</p>
<pre><code>CELERY_ROUTES = {
'myproject.tasks.do_work': {'queue': 'red'},
}
</code></pre>
<p>然后使用<code>celery worker -Q red</code>运行一个工作进程,它将只处理该队列中的事物(使用<code>celery worker</code>调用的另一个工作进程将只拾取默认队列中的事物)</p>
<p>文档中的<a href="http://docs.celeryproject.org/en/latest/userguide/routing.html">task routing</a>部分应该解释所有内容。</p>