调用Celery update_state后无法获取任务元数据(current-total)问题

你的核心问题出在views.py的processing分支中调用了result.get()——这个方法会阻塞当前请求，直到Celery任务完全执行完毕才返回响应。这导致前端发起的processing请求一直处于等待状态，根本没机会触发后续的checkstate轮询，自然拿不到任务执行过程中的进度数据。

修复步骤 #

1. 修改views.py，移除阻塞的同步调用 #

调用myFunction.delay()后直接返回任务ID即可，不要用result.get()（这是同步获取任务结果的方法，完全不适合异步进度追踪场景）。

修改后的views.py：

from django.http import JsonResponse
from celery.result import AsyncResult
from .tasks import myFunction

def my_view(request):  # 避免用view这种通用函数名，减少冲突
    if request.method == 'POST':
        if 'processing' in request.POST:
            result = myFunction.delay()
            request.session['task_id'] = result.id
            # 直接返回任务ID，让前端启动轮询
            return JsonResponse({'task_id': result.id})
        elif 'checkstate' in request.POST:
            task_id = request.session.get('task_id')
            if not task_id:
                return JsonResponse({'error': '任务ID不存在'}, status=400)
            task = AsyncResult(task_id)
            # task.info就是update_state传入的meta数据
            return JsonResponse({
                'state': task.state,
                'current': task.info.get('current') if task.info else 0,
                'total': task.info.get('total') if task.info else 100
            })
    # GET请求逻辑保留
    return JsonResponse({'status': 'ready'})

2. 确保tasks.py正确导入current_task #

你的tasks代码里用到了current_task，需要补上导入语句：

from celery import shared_task, current_task

@shared_task
def myFunction():
    current_task.update_state(state='PROGRESS', meta={'current':0, 'total':100})
    # 执行任务步骤1
    # ...
    current_task.update_state(state='PROGRESS', meta={'current':25, 'total':100})
    # 执行任务步骤2
    # ...
    current_task.update_state(state='PROGRESS', meta={'current':50, 'total':100})
    # ...
    current_task.update_state(state='PROGRESS', meta={'current':75, 'total':100})
    # ...
    current_task.update_state(state='PROGRESS', meta={'current':100, 'total':100})
    return {'result': '任务完成'}

3. 前端轮询逻辑优化 #

前端先发起processing请求拿到任务ID，再用定时器定时调用checkstate接口，直到任务状态变为SUCCESS或FAILURE：

function startTask() {
    fetch('/your-view-path/', {
        method: 'POST',
        headers: {'Content-Type': 'application/x-www-form-urlencoded'},
        body: 'processing=1'
    })
    .then(res => res.json())
    .then(data => {
        const taskId = data.task_id;
        // 每秒轮询一次进度
        const pollTimer = setInterval(() => {
            fetch('/your-view-path/', {
                method: 'POST',
                headers: {'Content-Type': 'application/x-www-form-urlencoded'},
                body: `checkstate=1`
            })
            .then(res => res.json())
            .then(pollData => {
                // 更新页面进度条
                // document.getElementById('progress').style.width = `${pollData.current}%`;
                console.log(`进度：${pollData.current}/${pollData.total}`);
                
                if (pollData.state === 'SUCCESS' || pollData.state === 'FAILURE') {
                    clearInterval(pollTimer);
                    // 任务结束后的处理逻辑
                }
            });
        }, 1000);
    });
}

额外注意事项 #

• 确保Celery的结果后端配置正确（比如Redis、数据库），否则AsyncResult无法获取任务状态和meta数据。
• 把任务ID存在session里可能有并发问题，建议前端直接存储任务ID并在轮询时传递，可靠性更高。

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