0

最近、自分の Reddit クローン (ubuntu 14.04 LTS) を開発することで、Python(2.7)/Django(1.5) を学習しています。Celery(3.1) と Redis をミックスに組み込み、それを使用して定期的にランキング アルゴをタスクとして (ローカルセットアップで) 実行しようとしています。しかし、残念ながら、この単純なタスクを一度も実行することはできません! 私が間違っていることを見つけるのを手伝ってもらえますか?

ここに私のディレクトリ構造があります:

-unconnectedreddit (manage.py is here)
    -links (tasks.py, models.py, views.py, admin.py)
    -unconnectedreddit (celery.py, __init.py___, settings.py, urls.py)
        -static
        -templates

Celery.py :

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

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'unconnectedreddit.settings')

app = Celery('unconnectedreddit', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0',include=['unconnectedreddit.links.tasks'])
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) 

app.conf.update(
    CELERY_TASK_RESULT_EXPIRES=3600,
)

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

settings.pyへの追加は以下の通りです。migrateインストールされたアプリに「djcelery」を追加した後に実行したことに注意してください。

INSTALLED_APPS = ('djcelery',)

import djcelery
djcelery.setup_loader()

BROKER_URL = 'redis://localhost:6379/0'

CELERY_IMPORTS = ('links.tasks', )  

CELERY_ALWAYS_EAGER = False

CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_IGNORE_RESULT=True

from datetime import timedelta

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

CELERY_TIMEZONE = 'UTC'

__init__.py :

from __future__ import absolute_import
from .celery import app as celery_app1

タスク.py :

import os
from unconnectedreddit import celery_app1
import time
from links.models import Link

@celery_app1.task
def rank_all():
    for link in Link.with_votes.all():
        link.set_rank() #ranks interesting 'links' submitted by users

ターミナルで次のコマンドを実行して、ワーカーを開始しています。celery -A unconnectedreddit worker -l info

私が得る出力は次のとおりです。

 -------------- celery@has-VirtualBox v3.1.18 (Cipater)
---- **** ----- 
--- * ***  * -- Linux-3.16.0-30-generic-x86_64-with-Ubuntu-14.04-trusty
-- * - **** --- 
- ** ---------- [config]
- ** ---------- .> app:         unconnectedreddit:0x7f938b838910
- ** ---------- .> transport:   redis://localhost:6379/0
- ** ---------- .> results:     redis://localhost:6379/0
- *** --- * --- .> concurrency: 1 (prefork)
-- ******* ---- 
--- ***** ----- [queues]
 -------------- .> celery           exchange=celery(direct) key=celery


[tasks]
  . links.tasks.rank_all

[2015-06-04 12:01:17,083: INFO/MainProcess] Connected to redis://localhost:6379/0
[2015-06-04 12:01:17,098: INFO/MainProcess] mingle: searching for neighbors
[2015-06-04 12:01:18,107: INFO/MainProcess] mingle: all alone
/home/has/.virtualenvs/unconnectedreddit/local/lib/python2.7/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 '

[2015-06-04 12:01:18,136: WARNING/MainProcess] /home/has/.virtualenvs/unconnectedreddit/local/lib/python2.7/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 '

[2015-06-04 12:01:18,137: WARNING/MainProcess] celery@has-VirtualBox ready.

それでおしまい。このタスクを 30 秒ごとに定期的に実行するように設定しました (私の CELERYBEAT_SCHEDULE を参照してください)。しかし、私のコードは 1 回も実行されません。私の reddit クローンのランキングはまったく変わりません。このセットアップに欠けているものを指摘できる専門家はいますか?

4

1 に答える 1

0

タスク名が間違っています。これは、タスク デコレータを次のように変更し@celery_app1.task(name='tasks.rank_all')、ビート スケジュールを微調整して正しい名前を含めることで修正されました。

CELERYBEAT_SCHEDULE = {
    'tasks.rank_all': {
        'task': 'tasks.rank_all',
        'schedule': timedelta(seconds=30),
    },
}
于 2015-06-05T08:40:18.573 に答える