Django计划任务

Question

我想在我的网站上显示当前美元/比特币价格对的汇率。为此，我设置了芹菜和一个小periodic_task。我现在真的不能理解如何调用这个periodic_task任务或者显示它返回的json数据。

这是我的celeter设置的样子：

__init_.py

    from __future__ import absolute_import, unicode_literals
    from .celery import app as celery_app

__all__ = ('celery_app',)

celery.py

from __future__ import absolute_import, unicode_literals
from celery import Celery
import os

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'myproject.settings')
app = Celery('myproject')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()


@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

tasks.py

from celery import Celery
from celery.schedules import crontab
from celery.task import periodic_task
from celery.utils.log import get_task_logger
import requests

logger = get_task_logger(__name__)
app = Celery('tasks', broker='redis://127.0.0.1')



@app.task
def test():
    return "Test Successful"


@periodic_task(run_every=(crontab(minute='*/15')), name="get_btc_exchange_rate", ignore_result=True)
def get_exchange_rate():
    api_url = "https://api.coinmarketcap.com/v1/ticker/?limit=1"
    try:
        exchange_rate = requests.get(api_url).json()
        logger.info("BTC Exchange rate updated.")
    except Exception as e:
        print(e)
        exchange_rate = dict()
    return exchange_rate

我现在用这个脚本来说明芹菜：https://gist.github.com/psych0der/44a8994495abee1b4e832420c1c2974d

所以我的问题是，如何触发periodic_task并显示json数据/字段"price_usd“的返回？在模板中

提前感谢

Answer 1

您需要启动一个celerybeat实例。它将调度和发送您可以按一定时间间隔设置的事件。

http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html