擅长:python、mysql、java
<p>所以我在这里看到了一些错误。首先,<code>tasks.py</code>中rabbitMQ的代理URL似乎不正确。它应该读像下面这样的东西。在</p>
<p><code>app = Celery('tasks', broker='amqp://ec2celeryuser:ec2celerypassword@xx.xxx.xx.xx/celeryserver1/')</code></p>
<p>此外,您可能希望在运行工作进程时指定希望celery提供服务的应用程序。您可以从<code>tasks.py</code>所在的目录运行<code>celery -A tasks worker</code>。在</p>
<p>另一件事是您在<code>client.py</code>中调用任务的代码似乎不正确。从celery文档中,可以按如下方式调用该任务:</p>
<pre><code>from tasks import add
result = add.delay(4, 4) # call task
result_sum = result.get(timeout=5) # wait to get result for a maximum of 5 seconds
</code></pre>
<p>解决这些问题也许能解决你的问题,或者至少能让你更亲近。在</p>