使用Ajax处理芹菜任务

我对如何继续我的程序有点困惑。我有一个django视图，要求用户输入名字和姓氏，然后这去一个芹菜任务处理数据并保存到数据库。现在，当任务正在处理时，我希望显示一个动画gif，以便用户知道正在发生某事。(我在SO的某个地方读到动画gif更好)然后如果任务完成，它会重定向到一个页面，告诉用户过程已经完成。我已经做了我的研究，发现我应该得到task_id并将其发送到ajax请求。

我的问题是如何使用ajax。我如何从ajax获得task_id ?或者将task_id传递给ajax请求。

编辑:我知道这是不完整的。很不完整的* *

这是我的一些代码。它没有做太多事情，因为我仍然需要掌握使用ajax的概念。但我想要的是，当我提交的形式，旋转gif将出现，同时，芹菜将处理我的任务。当celery完成任务后，它将重定向到一个页面，上面写着"Success"或其他内容。

views.py:

def addUser(request):
    if request.method == 'POST':
       addUser = userform(request.POST)
       if addUser.is_valid():
            task = create_user.apply_async((addUser.cleaned_data,), countdown=20)
       return render_to_response('loading.html', {'task_id': task.task_id})
    else:
       addUser = userform()
    return render(request, 'addUser.html', {'addUser':addUser})

addUser.html

<form method="POST">
    {% csrf_token %}
    {{ addUser }}
    <input type="submit" value="Submit">  
</form>

loading.html

<html>
<script>
<head>
<script src="{{ STATIC_URL }}js/jquery-ui.min.js"></script>
<script type="text/javascript">
var formData = task_id; // task id of my celery task
$.ajax({
    url : "templates/success.html", //from what I know, this URL is where the AJAX will go after processing
    type: "POST",
    data : formData,
    success: function(data, textStatus, jqXHR)
    {
        alert("Success")
    },
    error: function (jqXHR, textStatus, errorThrown)
    {
        alert("Failed")
    }
});
</script>
</head>
<body><center>
    {% load static %}
    <img src="{% static 'images/ripple.gif' %}" alt="Hi!" height="150" width="150" />
    </center>
</body>
</html>

tasks.py

@task(ignore_result=True)
def create_user(data):
    user = UserInfo(fname=data['fname'], lname=data['lname'])
    user.save()
    return None

我不确定AJAX会去哪里，如果它在form(addUser.html)或在loading.html

如果我错了，请纠正我。谢谢你的帮助!

这个想法是启动长时间运行的任务，当你执行一个时，它返回一个AsyncResult对象，你必须获得"task_id"并将其返回给客户端。例如，客户端(javascript)将向/check_status/发出GET请求，并将"task_id"传递给服务器。服务器将使用该task_id询问芹菜，并返回任务是否完成。

def view_with_task(request):
     #your code
     # send the task to the worker and get the task_id
     async_result = your_task.delay()
     #code
     ctx = {}
     ctx['task_id'] = async_result.task_id
     return render(tpl, ctx)
from celery import AsyncResult
def check_status(request):
    task_id = request.GET.get('task_id')
    if task_id:
        async_result = AsyncResult(task_id)
        return Jsonresponse({'finish': async_result.ready()})
    return JsonResponse({'finish': False})

顺便说一句，有一个项目可以做到这一点，没有太多的代码。由于

相关内容

最新更新

热门标签：