私はDjangoアプリケーション内で定期的なタスクを作成しようとしています。なぜセロリ周期的タスクは機能しませんか?
私は私のsettings.py
にこれを追加しました:
from datetime import timedelta
CELERYBEAT_SCHEDULE = {
'get_checkins': {
'task': 'api.tasks.get_checkins',
'schedule': timedelta(seconds=1)
}
}
を私はセロリを使い始めることだし、私が使用したいブローカー考え出したので、私はこれを追加しただけでなくちょうどブローカーをバイパスしていません当面:
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'testproject.settings')
app = Celery('testproject')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
:
if DEBUG:
CELERY_ALWAYS_EAGER = True
は、私も自分のプロジェクトフォルダ内celery.py
ファイルを作成しました私は労働者を実行し、それがうまく起動し、私はタスクが[tasks]
の下に登録されて見ることができますcelery -A testproject worker --beat -l info
で破ってる
from celery import shared_task
@shared_task
def get_checkins():
print('hello from get checkins')
:api
と呼ばれる私のアプリ、インサイド
は、私がtasks.py
ファイルを作りましたしかし、私は記録されている仕事はありません。毎秒1でなければなりません。なぜこれが実行されていないのか誰にも伝えられますか?
はあなただけ ' 'スケジュール' を試してみましたがいる:1.0'? –
これもうまくいくが、それまでのところ問題は解決していない。 – Rob