views.py 文件源码

def taskstatus(task_id):
    task = analyzetweets.AsyncResult(str(task_id))
    if task.state == "PENDING":
        response = {
            "state": task.state,
            "current": 0,
            "total": NUMBER_OF_TWEETS
        }
    elif task.state != "FAILURE":
        response = {
            "state": task.state,
            "current": task.info.get("current", 0),
            "total": NUMBER_OF_TWEETS
        }
        if "subjectivityavg" in task.info:
            response["subjectivityavg"] = task.info["subjectivityavg"]
            if "sentimentavg" in task.info:
                response["sentimentavg"] = task.info["sentimentavg"]
    else:
        response = {
            "state": task.state,
            "current": 1,
            "total": NUMBER_OF_TWEETS
        }
    return jsonify(response)