定期的な作業のためにウィンドウの下でCeleryを実行する方法がわからない

Question

いくつかのスケジュールされたタスクを設定した後にCeleryを実行する方法を理解できません。

次のようにまず、私のプロジェクトのディレクトリが構成されています

blogpodapi\api\__init__.pyは

from tasks import app 
import celeryconfig 

blogpodapi\api\celeryconfig.pyが

from datetime import timedelta 

# Celery settings 
CELERY_BROKER_URL = 'redis://localhost:6379/0' 
BROKER_URL = 'redis://localhost:6379/0' 
CELERY_RESULT_BACKEND = 'redis://localhost:6379/1' 
CELERY_ACCEPT_CONTENT = ['application/json'] 
CELERY_TASK_SERIALIZER = 'json' 
CELERY_RESULT_SERIALIZER = 'json' 
CELERY_TIMEZONE = 'UTC' 
CELERY_IMPORTS = ("api.tasks",) 

CELERYBEAT_SCHEDULE = { 
    'write-test': { 
     'task': 'api.tasks.addrandom', 
     'schedule': timedelta(seconds=2), 
     'args': (16000, 42) 
    }, 
} 

が含まれて含まれています

blogpodapi\api\tasks.py

... 

# Celery settings 
CELERY_BROKER_URL = 'redis://localhost:6379/0' 
BROKER_URL = 'redis://localhost:6379/0' 
CELERY_RESULT_BACKEND = 'redis://localhost:6379/1' 
CELERY_ACCEPT_CONTENT = ['application/json'] 
CELERY_TASK_SERIALIZER = 'json' 
CELERY_RESULT_SERIALIZER = 'json' 
CELERY_TIMEZONE = 'UTC' 
CELERY_IMPORTS = ("api.tasks",) 

... 

が含まれてい

from __future__ import absolute_import 

# This will make sure the app is always imported when 
# Django starts so that shared_task will use this app. 
from .celery import app as celery_app # noqa 

blogpodapi\blogpodapi\settings.pyが含まれてい

from __future__ import absolute_import 
import random 
from celery import Celery 
app = Celery('blogpodapi') 


@app.task 
def add(x, y): 
    r = x + y 
    print "task arguments: {x}, {y}".format(x=x, y=y) 
    print "task result: {r}".format(r=r) 
    return r 


@app.task 
def addrandom(x, *args): # *args are not used, just there to be interchangable with add(x, y) 
    y = random.randint(1,100) 
    print "passing to add(x, y)" 
    return add(x, y) 

blogpodapi\blogpodapi\__init__.pyが含まれています10

私は、コマンドプロンプトでcelery -A blogpodapi worker --loglevel=infoを実行すると、次を得る：

D:\blogpodapi>celery -A blogpodapi worker --loglevel=info 

-------------- celery@JM v3.1.23 (Cipater) 
---- **** ----- 
--- * *** * -- Windows-8-6.2.9200 
-- * - **** --- 
- ** ---------- [config] 
- ** ---------- .> app:   blogpodapi:0x348a940 
- ** ---------- .> transport: redis://localhost:6379/0 
- ** ---------- .> results:  redis://localhost:6379/1 
- *** --- * --- .> concurrency: 2 (prefork) 
-- ******* ---- 
--- ***** ----- [queues] 
-------------- .> celery   exchange=celery(direct) key=celery 


[tasks] 
    . api.tasks.add 
    . api.tasks.addrandom 
    . blogpodapi.celery.debug_task 

[2016-08-13 13:01:51,108: INFO/MainProcess] Connected to redis://localhost:6379/0 
[2016-08-13 13:01:52,122: INFO/MainProcess] mingle: searching for neighbors 
[2016-08-13 13:01:55,138: INFO/MainProcess] mingle: all alone 
c:\python27\lib\site-packages\celery\fixups\django.py:265: 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 ' 

[2016-08-13 13:02:00,157: WARNING/MainProcess] c:\python27\lib\site-packages\celery\fixups\django.py:265: 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 ' 

[2016-08-13 13:02:27,790: WARNING/MainProcess] celery@JM ready. 

私は、コマンドプロンプトでcelery -A blogpodapi beatを実行すると、次を得る：

D:\blogpodapi>celery -A blogpodapi beat 
celery beat v3.1.23 (Cipater) is starting. 
__ - ... __ -  _ 
Configuration -> 
    . broker -> redis://localhost:6379/0 
    . loader -> celery.loaders.app.AppLoader 
    . scheduler -> celery.beat.PersistentScheduler 
    . db -> celerybeat-schedule 
    . logfile -> [stderr]@%INFO 
    . maxinterval -> now (0s) 
[2016-08-13 13:02:51,937: INFO/MainProcess] beat: Starting... 

何らかの理由で、私が見るように見えることはできません私の定期的な仕事は記録されています。私が間違っていることは何ですか？

UPDATE：ここに私のcelery.pyがある...

from __future__ import absolute_import 
import os 
from celery import Celery 

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

from django.conf import settings # noqa 

app = Celery('blogpodapi') 

# 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)) 

Answer 1

あなたはセロリの設定が正確にあなたの `celery.pyである何

celery -A blogpodapi.celery beat --loglevel=INFO