セロリを実行できません。

Question

10秒ごとにサイトデータを取得するためにセロリが使用されています。したがって私はDjangoプロジェクトの設定を更新します。私はセロリでrabbitmqを使用しています。

settings.py

# This is the settings file 
# Rabbitmq configuration 
BROKER_URL = "amqp://abcd:abcd@localhost:5672/abcd" 

# Celery configuration 
CELERY_ACCEPT_CONTENT = ['json'] 
CELERY_TASK_SERIALIZER = 'json' 
CELERY_RESULT_SERIALIZER = 'json' 
CELERY_TIMEZONE = 'Asia/Kolkata' 
CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend' 
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler' 


CELERYBEAT_SCHEDULE = { 
    # Executes every Monday morning at 7:30 A.M 
    'update-app-data': { 
     'task': 'myapp.tasks.fetch_data_task', 
     'schedule': timedelta(seconds=10), 
     }, 

celery.py

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

# Indicate Celery to use the default Django settings module 
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'myproject.settings') 

app = Celery('myapp') 
app.config_from_object('django.conf:settings') 
# This line will tell Celery to autodiscover all your tasks.py that are in 
# playstore folders 
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) 

app_keywords = Celery('keywords') 
app_keywords.config_from_object('django.conf:settings') 
# This line will tell Celery to autodiscover all your tasks.py that are in 
# keywords folders 
app_keywords.autodiscover_tasks(lambda: settings.INSTALLED_APPS) 


app1 = Celery('myapp1') 
app1.config_from_object('django.conf:settings') 
# This line will tell Celery to autodiscover all your tasks.py that are in 
# your app folders 
app1.autodiscover_tasks(lambda: settings.INSTALLED_APPS) 

tasks.py

@task(bind=True) 
def fetch_data_task(self, data): 
    logger.info("Start task") 
    import pdb;pdb.set_trace() 
    # post the data to view 
    headers, cookies = utils.get_csrf_token() 
    requests.post(settings.SITE_VARIABLES['site_url'] + "/site/general_data/", 
        data=json.dumps(data), headers=headers, cookies=cookies 
       ) 
    if data['reviews']: 
     reviews_data = {'app_id': data['app_data'][ 
      'app_id'], 'reviews': data['reviews'][0]} 
     requests.post(settings.SITE_VARIABLES['site_url'] + "/site/blog/reviews/", 
         data=json.dumps(reviews_data), headers=headers, cookies=cookies 
        ) 
    logger.info("Task fetch data finished") 

今私はを呼び出したら、サイトへのログイン後、私のAPIのは、タスクはrabbimqでキューに入れられているし、引数と一緒に関数を呼び出す必要があります。ここで

これは、タスクをキューに入れ、タスクがそれぞれの時間を実行しますが、それは私に次のエラー

[2016-09-13 18:57:43,044: ERROR/MainProcess] Task playstore.tasks.fetch_data_task[3b88c6d0-48db-49c1-b7d1-0b8469775d53]

raised unexpected: TypeError("fetch_data_task() missing 1 required positional argument: 'data'",)

Traceback (most recent call last):

File "/Users/chitrankdixit/.virtualenvs/hashgrowth-> >dev/lib/python3.5/site-packages/celery/app/trace.py", line 240, in >trace_task R = retval = fun(*args, **kwargs) File "/Users/chitrankdixit/.virtualenvs/hashgrowth->dev/lib/python3.5/site-packages/celery/app/trace.py", line 438, in >protected_call return self.run(*args, **kwargs) TypeError: fetch_data_task() missing 1 required positional argument: 'data'

を与え、私は非常に最初の時間のためのタスクを呼び出しています

tasks.fetch_data_task.apply_async((data,))

ラインであります

誰かがセロリとrabbitmqで働いていて、セロリを使って定期的に仕事をしていたら、タスクを適切に実行するように勧めてください。

Answer 1

例外は、エラーの内容を示します。タスクでは定位置引数が必要ですが、スケジュール定義には引数を指定しません。

CELERYBEAT_SCHEDULE = { 
    # Executes every Monday morning at 7:30 A.M 
    'update-app-data': { 
     'task': 'myapp.tasks.fetch_data_task', 
     'schedule': timedelta(seconds=10), 
     'args': ({ 
      # whatever goes into 'data' 
     },) # tuple with one entry, don't omit the comma 
    }, 

コード内の他の場所からタスクを呼び出すことは、スケジュールに影響しません。