views.py 文件源码

def get_task_status(request):
    if request.method == 'POST':
        try:
            params = json.loads(request.body)
        except:
            return HttpResponseBadRequest(json.dumps({'error':'Json required'}),content_type="application/json")
        if not params.get("task_id"): 
            return HttpResponseBadRequest(json.dumps({'error':'task_id manadatory'}),content_type="application/json")
        try:
            task = Results.objects.get(id=params['task_id'])

            data = {'task_id':task.id,'result_file_name':task.result_file_name,'error':task.error,'percentage_done':task.percentage_done,
                    'status_text':task.status_text,'is_done':task.is_done,'pid':task.pid}
            return HttpResponse(json.dumps(data),content_type="application/json")
        except Results.DoesNotExist as e:
            return HttpResponseBadRequest(json.dumps({'error':'Invalid task_id'}),content_type="application/json")
    else:
        raise Http404()