芹菜周期性任务未执行

Question

我正在学习芹菜，我创建了一个测试配置的项目。我根据最新文档安装了celery==4.0.0和django-celery-beat==1.0.1。

在drf_project（带有manage.py的主项目dir）/drf_project/celery.py

from __future__ import absolute_import, unicode_literals
from celery import Celery
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'drf_project.settings')
app = Celery('drf_project')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

在drf_project/drf_project/settings.py

中

INSTALLED_APPS += ('django_celery_beat',)
CELERYBEAT_SCHEDULE = {
    "test_1": {
        "task": "tasks.print_test",
        "schedule": timedelta(seconds=2),
    },
}

在drf_project/drf_project/ init .py

from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app
__all__ = ['celery_app']

在我的user_management应用程序（drf_project/user_mangement/）中，我添加了一个任务。py

from celery import Celery
from time import strftime
app = Celery()
@app.task
def print_test():
    print strftime('%Y-%m-%d %H:%M:%S')
    with open('abc.txt', 'ab+') as test_file:
        test_file.writeline(strftime('%Y-%m-%d %H:%M:%S'))

当我运行芹菜工人和我的Django Project Dev Server时，请通过：

 celery -A drf_project worker -l info

和

 python manage.py runserver

我可以在芹菜日志中看到我的任务：

[tasks]
   . user_management.tasks.print_test

，但它没有执行。我也没有任何错误。那我做错了什么？我遵循芹菜的正式文档。

Answer 1

对于运行定期任务，您必须运行两个服务：芹菜节拍与 celery worker 。

您可以在下一页的底部找到更多信息。

Answer 2

这是我设置的docker-compose文件配置，用于运行芹菜工人和芹菜节。它可以完成工作。确保在下面的docker-compose文件中更改main_project_folder名称：

version: '3'
services:
  
  redis:
    image: "redis:latest"
    ports:
      - "6379:6379"
  worker:
    build:
      context: .
      dockerfile: Dockerfile
    image: madefire/chordtest
    command: bash -c "celery -A main_project_folder_name worker -l INFO"
    environment:
      - BROKER_URL=redis://redis:6379/0
      - RESULT_BACKEND=redis://redis:6379/0
      - C_FORCE_ROOT=true
    volumes:
      - ./:/app/
    depends_on:
      - redis
  celery_beat:
    build:
      context: .
      dockerfile: Dockerfile
    image: madefire/chordtest
    command: bash -c "celery -A main_project_folder_name beat"
    environment:
      - BROKER_URL=redis://redis:6379/0
      - RESULT_BACKEND=redis://redis:6379/0
      - C_FORCE_ROOT=true
    volumes:
      - ./:/app/
    depends_on:
      - redis