芹菜没有执行计划的、重复的任务

Question

我正在使用Django建立一个web服务器来监控股票的价格。因此，我希望每5秒出现一个任务(更新价格)，并通过控制台日志告诉我更新的情况。为什么西芹不按要求写控制台?

文件结构:

├── Project
│   ├── celery.py
│   ├── __init__.py
│   ├── settings.py
│   ├── urls.py
│   └── wsgi.py
├── manage.py
├── Application
│   ├── admin.py
│   ├── __init__.py
│   ├── migrations
│   ├── models.py
│   ├── serializers.py
│   |── tasks.py
│   |── tests.py
│   |── views.py

我的芹菜设置在settings.py:

# Celery
CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend'
CELERY_TASK_RESULT_EXPIRES = 3600
# Celery repeating tasks
CELERYBEAT_SCHEDULE = {
    'notify-every-10-seconds': {
         'task': 'Main.tasks.update',
         'schedule': timedelta(seconds=10),
    },
}

和任务本身:

from __future__ import absolute_import
from celery import shared_task
from .models import NasdaqShare

@shared_task
def update():
    print('Updated!')

当运行芹菜工作网络时，使用Django数据库，它似乎甚至将Application.tasks.update列为要运行的任务。

为什么我没有看到任何打印出来的东西来安慰他们?

如果您需要更多的信息，请告诉我。

Answer 1

确保您运行了芹菜节奏调度程序，例如celery -A Project beat