5

Celery 3.1.8、Django 1.6.1、および RabbitMQ で定期的なタスクを実行するのに問題があります。Celery を Django で実行するために django-celery はもう必要ないことを理解しているため、現在のドキュメントと少し混乱しています。ワーカーを正しく実行していないように感じますが、SO とグーグルで解決策を検索した後、助けが必要です。誰かがこれで私を正しい方向に向けることができますか?

settings.py (タスクに @periodic_task デコレーターがあるため、これが必要かどうかはわかりません)

CELERYBEAT_SCHEDULE = {
    'add-every-30-seconds': {
        'task': 'tasks.send_test_email',
        'schedule': datetime.timedelta(seconds=30)
    },
}

私のアプリ (celery.py)

from __future__ import absolute_import

import os
from celery import Celery
from django.conf import settings

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings')

app = Celery('app',
             broker='amqp://',
             backend='amqp://',
             include=['app.tasks'])


app.conf.update(
    CELERY_TASK_RESULT_EXPIRES=3600,
    CELERY_TIMEZONE='Europe/Oslo',
    )

if __name__ == '__main__':
    app.start()

# Using a string here means the worker will not have to
# pickle the object when using Windows.
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)


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

定期的なタスク (tasks.py)

from __future__ import absolute_import
from celery.task import periodic_task
import datetime

@periodic_task(run_every=datetime.timedelta(minutes=1))
def send_test_email():
    print "This is a periodic task from celery"

コマンド ラインで、ワーカーを実行しています。

celery worker -A app -l info
celery beat
4

1 に答える 1

1

他の解決策は、@periodic_task セロリデコレータを使用することです

from celery.schedules import crontab

@periodic_task(run_every=crontab(minute=0, hour=1))
def my_task():
    print 'my_task'
于 2015-01-20T17:43:42.693 に答える