Celery+Django+jQuery在jQuery中报告Celery任务的成功/失败

Question

我问了一个类似的问题，关于如何检测和报告芹菜任务何时完成（或失败）。这个问题集中在如何使用Django消息框架来实现这一点，而这对我来说是不必要的。我当前的方法是简单地发送一个JSON HttpResponse，并根据接收到的JSON呈现成功或失败消息。下面是我用来轮询任务状态的代码：

在视图.py公司名称：

def poll_state(request):
    if request.is_ajax():
        if 'task_id' in request.POST.keys() and request.POST['task_id']:
            task_id = request.POST['task_id']
            task = AsyncResult(task_id)
            if task.successful():
                logger.debug("Successful upload")
                return HttpResponse(json.dumps({"message":"Upload successful!", "state":"SUCCESS"}), content_type='application/json')
            elif task.failed():
                logger.debug("Error in upload")
                return HttpResponse(json.dumps({"message":"Error in upload!", "state":"FAILURE"}), content_type='application/json')
        else:
            logger.info('No task_id in the request')
    else:
        logger.info('Not an ajax request')

    result = task.result
    state = task.state
    response = {}
    response["percent"] = result["percent"]
    response["state"] = state
    json_data = json.dumps(response)
    return HttpResponse(json_data, content_type='application/json')

以及相应的jQuery（和Django模板）：

^{pr2}$

下面是任务本身的代码：

在任务.py公司名称：

@task(base=DBTask) # a custom base task class
def upload_task(datapoints, user, description): # datapoints is a list of dictionaries, user and description are strings
    from utils.db.databaseinserter import insertIntoDatabase
    for dp_count in insertIntoDatabase(datapoints, user, description): # insertIntoDatabase yields the number of datapoints inserted into the database so far at the end of each iteration
        percent_completion = int(100 * (float(dp_count) / float(len(datapoints))))
        current_task.update_state(state='PROGRESS', meta={'percent':percent_completion})

如果上传成功，那么一旦上传完成，控制台日志中就会出现JSON成功消息。如果上载有错误，则重新加载会使日志中出现错误消息。在这两种情况下，poll_state连续发送成功或失败的HttpResponse。另外，在开始一个新的任务后，我仍然会发送旧的任务信息，而不是当前的任务信息。接收当前任务信息的唯一时间是服务器首次启动时的第一个任务；对后续任务的任何轮询都将只获取第一个任务的信息。在

我做错什么了？我已经为这事绞尽脑汁了一段时间，但还是想不出来。这里的最终目标是在web页面上显示某种任务完成或任务失败的通知，而不是在完成之后重复发送成功/失败HttpResponse。在

我尝试过删除task.successful()和task.failed()块中的task}id会话键。这确实防止了成功/失败HttpResponse被重复发送，但是我仍然存在后续任务没有发送HttpResponse的问题；发生的情况是，一旦在第一个任务之后启动了一个新任务，就会发送第一个任务的HttpResponse，并且当前任务的百分比跟踪不再起作用。在

Answer 1

经过一番辛劳和挣扎，事实上，我所有问题的答案都是一句话。在

解决这个特殊问题的办法是改变

task_id = request.POST['task_id']

到

^{pr2}$

在poll_state中。在