как синтаксически вызвать функцию задачи сельдерея из внешнего модуля (* .py) - PullRequest
0 голосов
/ 09 марта 2020

У меня есть python скрипт forecast.py, который:

  • конечная точка API запроса

  • cat ответил json

  • сохранить в базу данных

Вот как код

import requests 

def get_fuxtures():
    #get data
    response = requests.get(fixture_endpoint,headers=header).json()

    #cat it 
    for item in response["api"]["fixtures"]:                                  
         fixture_id = item["fixture_id"]
         league_id = item["league_id"]                                                     
         event_date = item["event_date"]

         #save it
         fixt = Fixture.objects.create(fixture = fixture_id,league_id = league_id,                                 event_date = event_date)

Я хочу записать свой forecast.py как сельдерей задача и не понимают, как правильно вызвать импортированную get_fixtures() функцию из forecast.py как задачу сельдерея

from celery.decorators import task                       
from celery.utils.log import get_task_logger
import scripts.fixture as fx

@task()
 def get_data():
     fx.get_fixtures()

Вышеуказанная задача синтаксически верна

...