セロリを使い始めようとしていますが、私の仕事を動かすことができません。私はdjango-celery-beatとcelery4をインストールしました。セロリは定期的な仕事を拾わないでください

マイセッティングファイル。（セロリパッケージと）

インストール済みアプリの

... 
'django_celery_beat', 
'django_celery_results'

セロリ構成

CELERY_BROKER_URL = 'redis://localhost:6379/0' 
CELERY_RESULT_BACKEND = 'redis://localhost:6379' 
CELERY_ACCEPT_CONTENT = ['json'] 
CELERY_TASK_SERIALIZER = 'json' 
CELERY_RESULT_SERIALIZER = 'json'

celery.py

from __future__ import absolute_import, unicode_literals 
import os 
from celery import Celery 

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

app = Celery('sandbox') 

# Using a string here means the worker doesn't have to serialize 
# the configuration object to child processes. 
# - namespace='CELERY' means all celery-related configuration keys 
# should have a `CELERY_` prefix. 
app.config_from_object('django.conf:settings', namespace='CELERY') 

# Load task modules from all registered Django app configs. 
app.autodiscover_tasks() 


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

と私はを介して実行するように設定私の単純な作業で、 djangoセロリビートの管理パネル。

私は私の仕事が働いていない理由を私は取得していますログは、

$ celery -A sandbox worker --loglevel=debug 

[2017-10-24 14:28:02,999: DEBUG/MainProcess] | Worker: Preparing bootsteps. 
[2017-10-24 14:28:03,001: DEBUG/MainProcess] | Worker: Building graph... 
[2017-10-24 14:28:03,002: DEBUG/MainProcess] | Worker: New boot order: {Beat, Timer, Hub, Pool, Autoscaler, StateDB, Consumer} 
[2017-10-24 14:28:03,017: DEBUG/MainProcess] | Consumer: Preparing bootsteps. 
[2017-10-24 14:28:03,017: DEBUG/MainProcess] | Consumer: Building graph... 
[2017-10-24 14:28:03,038: DEBUG/MainProcess] | Consumer: New boot order: {Connection, Events, Mingle, Tasks, Control, Agent, Gossip, Heart, event loop} 

-------------- [email protected] v4.1.0 (latentcall) 
---- **** ----- 
--- * *** * -- Linux-4.9.0-kali3-amd64-x86_64-with-Kali-kali-rolling-kali-rolling 2017-10-24 14:28:03 
-- * - **** --- 
- ** ---------- [config] 
- ** ---------- .> app:   sandbox:0x7fe519d38610 
- ** ---------- .> transport: redis://localhost:6379/0 
- ** ---------- .> results:  redis://localhost:6379/ 
- *** --- * --- .> concurrency: 2 (prefork) 
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker) 
--- ***** ----- 
-------------- [queues] 
       .> celery   exchange=celery(direct) key=celery 


[tasks] 
    . celery.accumulate 
    . celery.backend_cleanup 
    . celery.chain 
    . celery.chord 
    . celery.chord_unlock 
    . celery.chunks 
    . celery.group 
    . celery.map 
    . celery.starmap 
    . sandbox.applications.cats.try_celery 
    . sandbox.celery.debug_task 

[2017-10-24 14:28:03,053: DEBUG/MainProcess] | Worker: Starting Hub 
[2017-10-24 14:28:03,053: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:03,053: DEBUG/MainProcess] | Worker: Starting Pool 
[2017-10-24 14:28:03,197: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:03,198: DEBUG/MainProcess] | Worker: Starting Consumer 
[2017-10-24 14:28:03,199: DEBUG/MainProcess] | Consumer: Starting Connection 
[2017-10-24 14:28:03,216: INFO/MainProcess] Connected to redis://localhost:6379/0 
[2017-10-24 14:28:03,217: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:03,217: DEBUG/MainProcess] | Consumer: Starting Events 
[2017-10-24 14:28:03,228: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:03,229: DEBUG/MainProcess] | Consumer: Starting Mingle 
[2017-10-24 14:28:03,229: INFO/MainProcess] mingle: searching for neighbors 
[2017-10-24 14:28:04,255: INFO/MainProcess] mingle: all alone 
[2017-10-24 14:28:04,256: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:04,256: DEBUG/MainProcess] | Consumer: Starting Tasks 
[2017-10-24 14:28:04,273: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:04,274: DEBUG/MainProcess] | Consumer: Starting Control 
[2017-10-24 14:28:04,277: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:04,277: DEBUG/MainProcess] | Consumer: Starting Gossip 
[2017-10-24 14:28:04,281: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:04,282: DEBUG/MainProcess] | Consumer: Starting Heart 
[2017-10-24 14:28:04,284: DEBUG/MainProcess] ^-- substep ok 
[2017-10-24 14:28:04,284: DEBUG/MainProcess] | Consumer: Starting event loop 
[2017-10-24 14:28:04,285: DEBUG/MainProcess] | Worker: Hub.register Pool... 
[2017-10-24 14:28:04,294: WARNING/MainProcess] /home/alexd/.virtualenvs/skate/local/lib/python2.7/site-packages/celery/fixups/django.py:202: 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 ' 
[2017-10-24 14:28:04,294: INFO/MainProcess] [email protected] ready. 
[2017-10-24 14:28:04,295: DEBUG/MainProcess] basic.qos: prefetch_count->8

ある*/2 * * * *

ようにcronタブで（ビート）定期的なタスクとして、このタスクを実行しようとしています

from __future__ import absolute_import, unicode_literals 
from sandbox.celery import app 


@app.task() 
def try_celery(): 
    print "Trying out Celery"

？セロリを実行しているの

更新

ログこれは、タスクが管理者に定期的なタスクとして作成された方法でタスクの

$ celery -A sandbox beat --loglevel=debug 
celery beat v4.1.0 (latentcall) is starting. 
Stale pidfile exists - Removing it. 
__ - ... __ -  _ 
LocalTime -> 2017-10-24 15:07:20 
Configuration -> 
    . broker -> redis://localhost:6379/0 
    . loader -> celery.loaders.app.AppLoader 
    . scheduler -> celery.beat.PersistentScheduler 
    . db -> celerybeat-schedule 
    . logfile -> [stderr]@%DEBUG 
    . maxinterval -> 5.00 minutes (300s) 
[2017-10-24 15:07:20,216: DEBUG/MainProcess] Setting default socket timeout to 30 
[2017-10-24 15:07:20,217: INFO/MainProcess] beat: Starting... 
[2017-10-24 15:07:20,372: DEBUG/MainProcess] Current schedule: 

[2017-10-24 15:07:20,373: DEBUG/MainProcess] beat: Ticking with max interval->5.00 minutes 
[2017-10-24 15:07:20,373: DEBUG/MainProcess] beat: Waking up in 5.00 minutes. 
[2017-10-24 15:15:43,232: DEBUG/MainProcess] beat: Synchronizing schedule... 
[2017-10-24 15:15:43,245: DEBUG/MainProcess] beat: Waking up in 5.00 minutes.

作成を破ったとして。

ps。私は間隔のオプションに変更した、私のcronのタブにいくつかの問題がありますか？とにかくまだ動作していない。

出典

2017-10-24 Rivadiz

次のようになります。//docs.celeryproject。あなたが '$ celery -A proj beat'を実行するセロリのビートスケジュールを開始するために、あなたが指定したものである可能性があります'ではない。 – sytech

質問をビートスケジューラの出力で更新しました。デフォルトの 'celery.beat.PersistentScheduler'を使用しているようです。 [ドキュメントに従って]（http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html#using-custom-scheduler-classes）、この拡張機能では、データベーススケジューラを使用します。ですから、ドキュメントが '--scheduler django_celery_beat.schedulers：DatabaseScheduler'のようにデータベーススケジューラを指定するオプションを追加してみてください。これが違いを生むかどうかを確認してください。また、データベースの移行を実行することを忘れないでください。 – sytech

よく私の問題を解決した@yytech、ありがとう。私はそれを受け入れてこの質問を閉じることができるように、あなたは答えを書くでしょうか？とにかくこれを設定ファイルに追加するには – Rivadiz

根本的な原因でワーカーを実行する必要が参照してくださいビートスケジューラは、適切な引数で起動する必要があるということです。あなたは、次のコマンドを入力：

$ celery -A sandbox worker --loglevel=debug

しかし、とセロリを開始するためにあなたがbeatではなくworkerを指定する必要があります（通常のセロリの労働者ではなく）、スケジュールを破りました。さらに、django_celery_beat拡張子を使用する場合は、デフォルトスケジューラcelery.beat.PersistentSchedulerではなく、データベーススケジューラdjango_celery_beat.schedulers:DatabaseSchedulerを使用する必要があります。

ように補正コマンドは、[ドキュメント]（HTTPによると

$ celery -A sandbox beat --loglevel=debug --scheduler=django_celery_beat.schedulers:DatabaseScheduler

Supporting documentation

出典

2017-10-24 15:39:00 sytech

あなたはcron shceduleを定義していないと思います。それはどこに保管されていますか？通常はディスク上またはデータベース上にあります（django_celery）。 http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html

はまた、あなたがこのケースでビートオプション

出典

2017-10-24 14:50:45

これはコメントでなければなりません。質問を更新しました。 – Rivadiz

セロリは定期的な仕事を拾わないでください

更新

答えて

関連する問題