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