셀러리가 실행할 수 없습니다.

Question

10 초마다 사이트 데이터를 가져 오는 셀러리 비트를 사용하고 있습니다. 따라서 장고 프로젝트의 설정을 업데이트합니다. 샐러리와 함께 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에 대기하고 그 다음 인수와 함께 함수를 호출해야합니다. 여기

내가이 작업을 대기열과 작업을 할 때마다 실행하지만 그것은 나에게 다음과 같은 오류를 제공

tasks.fetch_data_task.apply_async((data,))

난생 처음 작업을 호출하고있는 라인

[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'

셀러리와 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 
    }, 

코드의 다른 위치에서 작업을 호출해도 일정에 영향을주지 않습니다.