Django/Celery 快速入门示例不起作用（工作人员未执行任何任务）

Question

我正在使用Django/Celery Quickstart... or, how I learned to stop using cron and love celery，似乎作业正在排队，但从未运行。

tasks.py：

from celery.task.schedules import crontab
from celery.decorators import periodic_task

# this will run every minute, see http://celeryproject.org/docs/reference/celery.task.schedules.html#celery.task.schedules.crontab
@periodic_task(run_every=crontab(hour="*", minute="*", day_of_week="*"))
def test():
    print "firing test task"

所以我运行芹菜：

bash-3.2$ sudo manage.py celeryd -v 2 -B -s celery -E -l INFO  

/scratch/software/python/lib/celery/apps/worker.py:166: RuntimeWarning: Running celeryd with superuser privileges is discouraged!
  'Running celeryd with superuser privileges is discouraged!'))

 -------------- celery@myserver v3.0.12 (Chiastic Slide)
---- **** ----- 
--- * ***  * -- [Configuration]
-- * - **** --- . broker:      django://localhost//
- ** ---------- . app:         default:0x12120290 (djcelery.loaders.DjangoLoader)
- ** ---------- . concurrency: 2 (processes)
- ** ---------- . events:      ON
- ** ---------- 
- *** --- * --- [Queues]
-- ******* ---- . celery:      exchange:celery(direct) binding:celery
--- ***** ----- 

[Tasks]
  . GotPatch.tasks.test

[2012-12-12 11:58:37,118: INFO/Beat] Celerybeat: Starting...
[2012-12-12 11:58:37,163: INFO/Beat] Scheduler: Sending due task GotPatch.tasks.test (GotPatch.tasks.test)
[2012-12-12 11:58:37,249: WARNING/MainProcess] /scratch/software/python/lib/djcelery/loaders.py:132: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
  warnings.warn("Using settings.DEBUG leads to a memory leak, never "
[2012-12-12 11:58:37,348: WARNING/MainProcess] celery@myserver ready.
[2012-12-12 11:58:37,352: INFO/MainProcess] consumer: Connected to django://localhost//.
[2012-12-12 11:58:37,700: INFO/MainProcess] child process calling self.run()
[2012-12-12 11:58:37,857: INFO/MainProcess] child process calling self.run()
[2012-12-12 11:59:00,229: INFO/Beat] Scheduler: Sending due task GotPatch.tasks.test (GotPatch.tasks.test)
[2012-12-12 12:00:00,017: INFO/Beat] Scheduler: Sending due task GotPatch.tasks.test (GotPatch.tasks.test)
[2012-12-12 12:01:00,020: INFO/Beat] Scheduler: Sending due task GotPatch.tasks.test (GotPatch.tasks.test)
[2012-12-12 12:02:00,024: INFO/Beat] Scheduler: Sending due task GotPatch.tasks.test (GotPatch.tasks.test)

任务确实在排队：

python manage.py shell
>>> from kombu.transport.django.models import Message
>>> Message.objects.count()
234

随着时间的推移计数会增加：

>>> Message.objects.count()
477

日志文件中似乎没有任何行表明任务正在执行。我期待类似的东西：

[... INFO/MainProcess] Task myapp.tasks.test[39d57f82-fdd2-406a-ad5f-50b0e30a6492] succeeded in 0.00423407554626s: None

对如何诊断/调试有什么建议吗？

Answer 1

我也是 celery 的新手，但是从您提供的链接上的 cmets 来看，教程中似乎有错误。其中一位cmets指出：

在这个命令下

sudo ./manage.py celeryd -v 2 -B -s celery -E -l INFO

必须添加“-I tasks”才能加载tasks.py文件...

你试过了吗？

Answer 2

您应该检查您是否在 django 的 settyngs.py 中指定了 BROKER_URL 参数。

BROKER_URL = 'django://'

并且您应该检查您在 django、mysql 和 celery 中的时区是否相等。 它帮助了我。

附：

[... INFO/MainProcess] Task myapp.tasks.test[39d57f82-fdd2-406a-ad5f-50b0e30a6492] succeeded in 0.00423407554626s: None

此行表示您的任务已安排（！未执行！）

请检查您的配置，希望对您有所帮助。

Answer 3

我希望有人可以从我的黑客经验中学习。

根据教程设置完所有内容后，我注意到当我调用时

add.delay(4,5)

什么都没有发生。工作人员没有收到任务（stderr 上没有打印任何内容）。

问题出在 rabbitmq 安装上。事实证明，默认的可用磁盘大小要求是 1GB，这对我的 VM 来说太大了。

让我走上正轨的是阅读 rabbitmq 日志文件。 为了找到它，我不得不停止并启动 rabbitmq 服务器

sudo rabbitmqctl stop
sudo rabbitmq-server

rabbitmq 将日志文件位置转储到屏幕上。在文件中我注意到了这一点：

=WARNING REPORT==== 14-Mar-2017::13:57:41 ===
disk resource limit alarm set on node rabbit@supporttip.

**********************************************************
*** Publishers will be blocked until this alarm clears ***
**********************************************************

然后我按照此处的说明来减少可用磁盘限制 Rabbitmq ignores configuration on Ubuntu 12

作为基线，我使用了来自 git 的配置文件 https://github.com/rabbitmq/rabbitmq-server/blob/stable/docs/rabbitmq.config.example

变化本身：

{disk_free_limit, "50MB"}