Django 计划任务

Question

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

这就是我的 celeter 设置的样子：

__init_.py

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

__all__ = ('celery_app',)

芹菜.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

我目前正在用这个脚本说明 celery： https://gist.github.com/psych0der/44a8994495abee1b4e832420c1c2974d

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

提前致谢

Answer 1

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

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