理解芹菜有问题

这是我第一次学习芹菜和django。我已经在我的virtualenv中安装了最新版本的芹菜（celery==3.1.17）和拉比q（amqp==1.4.6）。我在西芹的网站上学习。

models.py:

from django.db import models
# Create your models here.
class Count(models.Model):
    x = models.IntegerField()
    def __unicode__(self):
        return self.x

views.py:

def home(request):
    if request.POST:
        form = CountForm(request.POST)
        if form.is_valid():
            if form.cleaned_data:
                count = form.save()
                count.x = add.delay(count.x)
                return HttpResponseRedirect('/')
    else:
        all_counts = Count.objects.all()
        form = CountForm()
    return render(request, 'home.html',{
        'form':form,
        'all_counts':all_counts
        })

模板：

<body>
    <form method="post" action=".">
        {% csrf_token %}
        {{form.as_p}}
        <input type="submit" value="post">
    </form>
    {% if all_counts.count > 0 %}
        {% for count in all_counts %}
            <p>ID {{count.id}} =  :: Value = {{count.x}}</p>
            <br/>
        {% endfor %}
    {% else %}
        <p>No counts</p>
    {% endif %}
</body>

更新

tasks.py:

@app.task
def add(x):
    while x <= 50:
        return x + 1
        time.sleep(3)

我想通过芹菜执行的是将Count的x相加，直到它等于50，这样每个计算和结果值都将异步存储因此，在每3秒之后，我应该看到count.x的值异步变化，直到值为50。但在模板中，我得到的值与我发布的值相同。我错过了什么？你能帮我理解吗。非常感谢。

芹菜不适合这个。

您想要做的事情可以用纯js实现，甚至可以用ajax django视图实现。

您可以使用js中的计时器对服务器进行异步调用，并每隔3秒询问当前值。然后，您应该使用js甚至JQuery相应地更新html。

查看Django REST框架。使用对服务器的异步调用非常方便。

芹菜的用途

Celery用于繁重的后台任务，这些任务可以由不同的机器或异步执行，这样请求就不会在高处理时间内超时，或者资源得到更好的管理。它不会做任何与模板渲染相关的事情，因为它主要是一个任务队列实用程序。

调用add.delay在worker中启动异步任务，并立即返回AsyncResult对象。如果要访问任务的实际返回值，则需要调用AsyncResult.get()。这将被阻止，直到在工作者中完成任务为止。

return_value = add.delay(count.x).get()

更多详细信息，请参阅文档。

相关内容

最新更新

热门标签：