当金字塔正在运行进程时，如何显示“处理”或“正在进行”视图？

Question

我已经启动并运行了一个简单的金字塔应用程序，大多数视图都是围绕sqlite数据库的一个相当薄的包装，其中包含一些表单来编辑/添加一些信息。

每月有几次，需要将新数据块添加到该系统（通过csv导入）。数据保存在一个SQL表中（整个过程直到提交需要大约4秒）。

每次上传新的数据块时，都会触发对数据库中其他表的重新计算。重新计算过程需要相当长的时间（一个月的数据大约需要21-50秒）。

目前，我只是让浏览器/客户端坐在那里等待过程完成，但我确实预见到，随着系统使用率的提高，计算过程会花费越来越多的时间。从UI的角度来看，这显然看起来像一个挂起的过程。

我可以做些什么来向用户表明：-

>

他们还要等多久（进度条等）？

注意：我并不是在这里询问长轮询或WebSocket，因为这不是一个真正的交互式应用程序，而且基于我的基本知识，WebSocket/async对于我来说太过复杂了。

我想在这一点上还有一个后续问题，我在视图函数中运行进程是不是做错了？似乎很少看到在网络上的例子/教程中这样做。在这种情况下，我应该用芹菜或类似的东西吗？

Answer 1

那么，长时间运行的过程是由浏览器操作触发的吗？也就是说，用户正在上传得到处理的CSV，然后视图就在那里进行处理？对于短时间运行的浏览器进程，我通过jQuery或javascript使用了一个加载指示器，基本上是在进程运行时弹出一个模式动画微调器或其他东西，然后当它完成隐藏微调器时。

但是，如果你进入越来越长的流程，我认为你真的应该考虑一些后台处理，将其从UI中卸载。它不必是基于消息的工作者，但即使是最终用户上传文件，并在数据库中设置“待处理”条目之类的东西。然后，可以在后台定期安排一个金字塔脚本，轮询状态表并运行它找到的任何内容。您可以将视图中的文件处理移动到单独的方法，并且可以从命令行脚本调用该方法。然后，当处理完成时，它可以更新状态表，表明它已经完成，并且反馈可以在某个地方返回给用户，而不会一直阻塞用户界面。

Answer 2

你说得对，在视图函数中进行长时间的计算通常是不被允许的——我的意思是，如果这是一个典型的网站，有随机的访问者，他们能够挂一个网络服务器线程一分钟，那么这就是DoS漏洞的根源。但是在某些情况下（内部网站，很少用户，只有管理员可以访问上传csv表单），你可能会逃脱惩罚。事实上，我曾经有运行几个小时的维护脚本：）

这里的诀窍是避免浏览器超时——此时，您的客户机将数据发送到服务器，只是坐在那里等待任何回复，而不知道他们的请求是否正在被处理。通常，在大约60秒时，浏览器（或代理，或前端Web服务器）可能会变得不耐烦并关闭连接。然后，服务器进程将在尝试向已关闭的连接写入任何内容时出错，并导致崩溃/引发错误。

为了防止这种情况发生，服务器需要定期向连接写入内容，以便客户端看到服务器处于活动状态，并且不会关闭连接。

"普通"金字塔模板被缓冲-即直到生成整个模板才将输出发送到客户端。因此，您需要直接使用response.app_iter/response.body_file并定期输出一些数据。

例如，您可以从金字塔Cookbook复制Todo List Application in One File示例，并将new_view函数替换为以下代码（其本身已从本问题中借用）：

@view_config(route_name='new', request_method='GET', renderer='new.mako')
def new_view(request):
    return {}


@view_config(route_name='new', request_method='POST')
def iter_test(request):
    import time

    if request.POST.get('name'):
        request.db.execute(
            'insert into tasks (name, closed) values (?, ?)',
            [request.POST['name'], 0])
        request.db.commit()


    def test_iter():
        i = 0
        while True:
            i += 1
            if i == 5:
                yield str('<p>Done! <a href="/">Click here</a> to see the results</p>')
                raise StopIteration
            yield str('<p>working %s...</p>' % i)
            print time.time()
            time.sleep(1)

    return Response(app_iter=test_iter())

（当然，这个解决方案在用户界面方面不是很花哨，但你说过你不想弄乱WebSocket和芹菜）