芹菜中的简单周期性任务不起作用但没有错误

Question

我是 Celery 的新手。我正在尝试使用我的 Django 项目正确配置 Celery。为了测试芹菜是否有效，我创建了一个周期性任务，它应该每 2 秒打印一次 "periodic_task"。不幸的是它不起作用，但没有错误。

1 安装rabbitmq

2 Project/project/celery.py

from __future__ import absolute_import

import os

from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')

from django.conf import settings  # noqa

app = Celery('project')

app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

@app.task(bind=True)
def myfunc():
    print 'periodic_task'

@app.task(bind=True)
def debudeg_task(self):
    print('Request: {0!r}'.format(self.request))

3 Project/project/__init__.py

from __future__ import absolute_import

from .celery import app as celery_app

4 Settings.py

INSTALLED_APPS = [
    'djcelery',
    ...]
...
...

CELERYBEAT_SCHEDULE = {
  'schedule-name': {
                      'task': 'project.celery.myfunc',  # We are going to create a email_sending_method later in this post.
                      'schedule': timedelta(seconds=2),
                      },
  }

而在python manage.py之前，我运行celery -A project worker -l info

仍然看不到控制台每 2 秒打印任何 "periodic_task"...您知道该怎么做吗？

编辑芹菜控制台：

 -------------- celery@Milwou_NB v3.1.23 (Cipater)
---- **** -----
--- * ***  * -- Windows-8-6.2.9200
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app:         dolava:0x33d1350
- ** ---------- .> transport:   amqp://guest:**@localhost:5672//
- ** ---------- .> results:     disabled://
- *** --- * --- .> concurrency: 4 (prefork)
-- ******* ----
--- ***** ----- [queues]
 -------------- .> celery           exchange=celery(direct) key=celery


[tasks]
  . project.celery.debudeg_task
  . project.celery.myfunc

编辑：

把worker换成beat后，好像可以了。每 2 秒（更改为 5 秒）就会发生一些事情，但我看不到任务的结果。（我可以将任何东西放入 CELERYBEAT_SCHEDULE，即使是错误的路径也不会引发任何错误..）

我将 myfunc 代码更改为：

@app.task(bind=True)
def myfunc():
    # notifications.send_message_to_admin('sdaa','dsadasdsa')
    with open('text.txt','a') as f:
        f.write('sa')

但是我在任何地方都看不到 text.txt。

> celery -A dolava beat -l info
celery beat v3.1.23 (Cipater) is starting.
__    -    ... __   -        _
Configuration ->
    . broker -> amqp://guest:**@localhost:5672//
    . loader -> celery.loaders.app.AppLoader
    . scheduler -> djcelery.schedulers.DatabaseScheduler

    . logfile -> [stderr]@%INFO
    . maxinterval -> now (0s)
[2016-10-26 17:46:50,135: INFO/MainProcess] beat: Starting...
[2016-10-26 17:46:50,138: INFO/MainProcess] Writing entries...
[2016-10-26 17:46:51,433: INFO/MainProcess] DatabaseScheduler: Schedule changed.

[2016-10-26 17:46:51,433: INFO/MainProcess] Writing entries...
[2016-10-26 17:46:51,812: INFO/MainProcess] Scheduler: Sending due task schedule-name (dolava_app.tasks.myfunc)
[2016-10-26 17:46:51,864: INFO/MainProcess] Writing entries...
[2016-10-26 17:46:57,138: INFO/MainProcess] Scheduler: Sending due task schedule-name (dolava_app.tasks.myfunc)
[2016-10-26 17:47:02,230: INFO/MainProcess] Scheduler: Sending due task schedule-name (dolava_app.tasks.myfunc)

Answer 1

尝试运行

$ celery -A project beat -l info

芹菜中的简单周期性任务不起作用但没有错误

Simple periodic task in celery doesn't work but no errors

python

django

celery

django-celery