|
@@ -127,11 +127,12 @@ configuration:</p>
|
|
|
<span class="n">AMQP_PASSWORD</span> <span class="o">=</span> <span class="s">"secret"</span>
|
|
|
<span class="n">AMQP_VHOST</span> <span class="o">=</span> <span class="s">"myapp"</span>
|
|
|
|
|
|
-<span class="n">CELERY_AMQP_CONSUMER_QUEUE</span> <span class="o">=</span> <span class="s">"feed_tasks"</span>
|
|
|
<span class="n">CELERY_AMQP_EXCHANGE</span> <span class="o">=</span> <span class="s">"tasks"</span>
|
|
|
<span class="n">CELERY_AMQP_PUBLISHER_ROUTING_KEY</span> <span class="o">=</span> <span class="s">"task.regular"</span>
|
|
|
-<span class="n">CELERY_AMQP_CONSUMER_ROUTING_KEY</span> <span class="o">=</span> <span class="s">"task.feed.#"</span>
|
|
|
<span class="n">CELERY_AMQP_EXCHANGE_TYPE</span> <span class="o">=</span> <span class="s">"topic"</span>
|
|
|
+<span class="c"># This is the settings different for this server:</span>
|
|
|
+<span class="n">CELERY_AMQP_CONSUMER_QUEUE</span> <span class="o">=</span> <span class="s">"feed_tasks"</span>
|
|
|
+<span class="n">CELERY_AMQP_CONSUMER_ROUTING_KEY</span> <span class="o">=</span> <span class="s">"feed.#"</span>
|
|
|
</pre></div>
|
|
|
</div>
|
|
|
</blockquote>
|
|
@@ -142,7 +143,7 @@ configuration:</p>
|
|
|
|
|
|
<span class="k">class</span> <span class="nc">FeedImportTask</span><span class="p">(</span><span class="n">Task</span><span class="p">):</span>
|
|
|
<span class="n">name</span> <span class="o">=</span> <span class="s">"import_feed"</span>
|
|
|
- <span class="n">routing_key</span> <span class="o">=</span> <span class="s">"task.feed.importer"</span>
|
|
|
+ <span class="n">routing_key</span> <span class="o">=</span> <span class="s">"feed.importer"</span>
|
|
|
|
|
|
<span class="k">def</span> <span class="nf">run</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">feed_url</span><span class="p">):</span>
|
|
|
<span class="c"># something importing the feed</span>
|
|
@@ -154,7 +155,7 @@ configuration:</p>
|
|
|
<div class="highlight-python"><div class="highlight"><pre><span class="gp">>>> </span><span class="kn">from</span> <span class="nn">celery.task</span> <span class="kn">import</span> <span class="n">apply_async</span>
|
|
|
<span class="gp">>>> </span><span class="kn">from</span> <span class="nn">myapp.tasks</span> <span class="kn">import</span> <span class="n">RefreshFeedTask</span>
|
|
|
<span class="gp">>>> </span><span class="n">apply_async</span><span class="p">(</span><span class="n">RefreshFeedTask</span><span class="p">,</span> <span class="n">args</span><span class="o">=</span><span class="p">[</span><span class="s">"http://cnn.com/rss"</span><span class="p">],</span>
|
|
|
-<span class="gp">... </span> <span class="n">routing_key</span><span class="o">=</span><span class="s">"task.feed.importer"</span><span class="p">)</span>
|
|
|
+<span class="gp">... </span> <span class="n">routing_key</span><span class="o">=</span><span class="s">"feed.importer"</span><span class="p">)</span>
|
|
|
</pre></div>
|
|
|
</div>
|
|
|
</div>
|