Django集成Celery后任务无法自动执行，求自动化运行方案

看起来你已经把Django和Celery的基础配置捋顺了——页面无限加载的核心原因是：你在视图里用了result.get()，这个方法会阻塞当前Ajax请求，直到Celery任务执行完成。但启动Django时Celery Worker没跟着跑，任务一直卡在消息队列里，请求自然永远等不到结果。手动启动Worker后任务能正常执行，说明配置本身没问题，只是需要让Worker和Django一起自动化启动。

下面给你分场景推荐几种方案：

一、本地开发环境：简单启动脚本/进程管理工具 #

方案1：写个启动脚本（最直接） #

针对Linux/macOS，在项目根目录创建start_dev.sh：

#!/bin/bash
# 后台启动Celery Worker
celery -A converter worker --loglevel=info &
# 启动Django开发服务器
python manage.py runserver

给脚本加执行权限：chmod +x start_dev.sh，之后运行./start_dev.sh就能同时启动两者。

Windows用户可以创建start_dev.bat：

start celery -A converter worker --loglevel=info
python manage.py runserver

双击bat文件即可同时启动两个进程。

方案2：用Honcho管理多进程（更优雅） #

Honcho是轻量的进程管理工具，适合本地开发统一管理多个服务：

1. 安装Honcho：pip install honcho
2. 在项目根目录创建Procfile：

web: python manage.py runserver
worker: celery -A converter worker --loglevel=info

3. 启动所有进程：honcho start
   它会把Django和Celery的日志统一输出，方便调试。

二、生产环境：用systemd实现开机自启 #

生产环境不建议把Worker和Web服务器放一起，推荐用systemd管理Celery Worker，让它随系统自动启动：

1. 在/etc/systemd/system/下创建celery.service：

[Unit]
Description=Celery Worker Service
After=network.target

[Service]
User=你的系统用户名
Group=你的系统用户组
WorkingDirectory=/你的项目绝对路径
Environment="PATH=/你的虚拟环境路径/bin"
ExecStart=/你的虚拟环境路径/bin/celery -A converter worker --loglevel=info

[Install]
WantedBy=multi-user.target

2. 执行以下命令启动并设置开机自启：

sudo systemctl daemon-reload
sudo systemctl start celery
sudo systemctl enable celery

之后Celery Worker会随系统自动运行，Django服务可以用Nginx+Gunicorn/uWSGI单独部署，两者独立运行更稳定。

额外优化：避免请求阻塞 #

你当前的视图用result.get()直接阻塞请求的方式，在生产环境很容易超时。更合理的做法是：

1. 提交任务后立即返回任务ID给前端
2. 前端通过轮询或WebSocket查询任务状态
3. 任务完成后再获取结果

修改后的视图示例：

from celery.result import AsyncResult
from .tasks import add

class AddAjaxView(JSONResponseMixin, AjaxResponseMixin, View):
    def post_ajax(self, request, *args, **kwargs):
        # 修正原代码中的任务调用错误（原代码写了tasks.convert.delay，应该是add）
        number1 = int(request.POST.get('number1', 0))
        number2 = int(request.POST.get('number2', 0))
        task = add.delay(number1, number2)
        return self.render_json_response({'task_id': task.id}, status=200)

# 新增查询任务状态的视图
class TaskStatusView(JSONResponseMixin, View):
    def get(self, request, task_id):
        result = AsyncResult(task_id)
        data = {
            'is_ready': result.ready(),
            'result': result.get() if result.ready() else None,
            'status': result.status
        }
        return self.render_json_response(data)

前端用setInterval定期请求TaskStatusView，直到任务完成再展示结果，这样就不会出现页面无限加载的情况，用户体验也更好。

内容的提问来源于stack exchange，提问作者Little Phild