Django - 如何在 celery 和 redis 中使用异步任务队列答案

【问题标题】：Django - How to use asynchronous task queue with celery and redisDjango - 如何在 celery 和 redis 中使用异步任务队列
【发布时间】：2015-11-14 13:47:54
【问题描述】：

#In my views.py file
pi1 = None
pis1 = None
def my_func():
    #Essentially this function sets a random integer to pi1 and pis1
    global pi1, pis1
    pi1 = randint(0,9)
    pis1 = randint(0,9)
    return        

def index(request):

    my_func()

    context = {
        "pi1" : pi1,
        "pis1" : pis1,
    }

    return render(request, "index.html", context)

#In the index.html file
<h1>{{ pi1 }}</h1>
<h1>{{ pis1 }}</h1>

为了简单起见，我删除了很多代码，但这就是它的要点。尽管我为 my_func 发布了代码，但它是一个耗时的函数，它会导致 index.html 在被访问时加载一段时间。如何使用 celery 和 redis 在后台运行 my_func 以便 index.html 加载更快？

我已阅读 celery 文档，但我仍然无法设置 celery 和 redis。谢谢。

【问题讨论】：

这样：context = { "pi1" : pi1, "pis1" : pis1, } 工作吗？
一切正常，只是速度很慢。

标签： python django asynchronous redis celery

【解决方案1】：

如前所述，您可能不需要芹菜。这是从案例 2 派生的示例：https://zapier.com/blog/async-celery-example-why-and-how/。它完全适合我：

from time import sleep
import json
from django.http import HttpResponse
from django.shortcuts import render

def main_view(request):
    return render(request, 'index.html')

def ajax_view(request):
    sleep(10) #This is whatever work you need
    pi1 = "This is pi1" #I just made pi1/pis1 random values
    pis1 = "This is pis1"
    context = {
        "pi1" : pi1,
        "pis1" : pis1,
    }
    data = json.dumps(context)

    return HttpResponse(data, content_type='application/json')

我的 index.html 包含：

<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="utf-8">
    <title>Main View</title>
    <script src="//code.jquery.com/jquery-1.11.3.min.js"></script>
    <script>
    $(document).ready(function(){
        $.ajax({
            url: "/test_ajax/",
        }).done(function( data) {
            $("#pi1").text(data.pi1);
            $("#pis1").text(data.pis1); 
        });
    });
</script>
  </head>
  <body>
      <h1 id = "pi1">Loading</h1>
      <h1 id = "pis1">Loading</h1>
  </body>
</html>

我的 urls.py 包含：

from django.conf.urls import include, url
from django.contrib import admin
from testDjango.test import main_view, ajax_view

urlpatterns = [
    url(r'^admin/', include(admin.site.urls)),
    url(r'^test/', main_view),
    url(r'^test_ajax/', ajax_view)
]

当我访问 localhost:8000/test/ 时会发生什么我立即看到：

大约 10 秒后，我看到了：

这个想法是您立即返回您的页面并使用 jquery 在完成时获取操作结果并相应地更新您的页面。您可以添加更多内容，例如进度条/加载图像等。例如，您可以在后台对pi1 和pis 进行处理，并在完成后将其加载到 HTML 中。

【讨论】：

谢谢你的想法，但你能解释一下javascript部分吗？我不明白你在那里做什么。
另外，在阅读了您链接的页面后，我的印象是这不会更快地加载我的页面，但它只会让我在页面上添加一个加载栏。
让我们为此添加一些数字。如果您的 pi1 和 pis1 需要大约 10 秒的时间来计算。您必须在某个时间点花费 10 秒的时间来计算。除非您已经有缓存值，否则您无法真正避免这种情况。从我展示的链接中，如果你不使用任何异步的东西，用户必须提前等待这 10 秒。当他们看到一个空白页面时，他们必须等待 10 秒。 async 的作用是让您显示某些内容，并在用户等待 10 秒时将页面控制权交还给用户。这意味着不再有空白页，这使它变得更好。
Celery 不会让你避免等待这 10 秒，而不是使用这样的东西。芹菜的好处来自于你需要做很多工作的时候。如果你只是偶尔需要一件东西，那真的不需要。无论如何，在我的示例中，javascript 所做的是，当页面加载时，它使用 AJAX 发送请求以获取 pis 和 pi1s` 的信息，然后用 @ 的值填充
s 987654335@ 和 pis1 在你进行了 10 秒的计算之后。这样，用户将获得他们想要的信息，而无需一直看着空白屏幕。
JSON 是一种数据格式。它不是特定于javascript的。我把它放到 JSON 中，因为它相当容易阅读并且是可移植的。 jQuery 是一个方便的 javascript 包。它有一个名为.ajax 的函数，这是我用过的。您可以在这里阅读有关 ajax 的基本概念：learn.jquery.com/ajax

【解决方案2】：

这里不需要芹菜。您可以使用 AJAX 请求在页面上加载这些值。您应该创建一个单独的视图来计算这些值，并在加载 index.html 后使用 javascript 调用它。

【讨论】：

我很困惑，你能给我举个例子吗？谢谢。

s 987654335@ 和 pis1 在你进行了 10 秒的计算之后。这样，用户将获得他们想要的信息，而无需一直看着空白屏幕。

s 987654335@ 和 `pis1` 在你进行了 10 秒的计算之后。这样，用户将获得他们想要的信息，而无需一直看着空白屏幕。