如何从 Twisted 中推迟 Django DB 操作？

Question

我有一个正常的 Django 站点正在运行。此外，还有另一个扭曲的进程，它监听 Jabber 存在通知并使用 Django 的 ORM 更新 Django DB。

到目前为止，它的工作原理是我只是调用相应的 Django 模型（在正确设置设置环境之后）。然而，这会阻止 Twisted 应用程序，这不是我想要的。

由于我是扭曲的新手，我不知道最好的方法是使用延迟以非阻塞方式访问 Django DB（通过其 ORM）。

1. 延迟生成器？
2. 扭曲的企业.adbapi？ （绕过 ORM？）
3. ？？？

如果解析了存在消息，我想将具有 jid_str 的用户在线/离线状态保存在 Django DB 中（使用 Django 模型 UserProfile）。我用这个函数来做：

def django_useravailable(jid_str, user_available):
    尝试：
        userhost = jid.JID(jid_str).userhost()
        用户 = UserProfile.objects.get(im_jabber_name=userhost)
        user.im_jabber_online = user_available
        用户.save()
        返回 jid_str, user_available
    除了异常，e：
        打印 e
    引发 jid_str, user_available,e

目前，我通过以下方式调用它：

d = threads.deferToThread(django_useravailable, from_attr, user_available)
d.addCallback(self.success)
d.addErrback(self.failure)

Answer 1

“我有一个正常的 Django 站点正在运行。”

大概在 Apache 下使用 mod_wsgi 或类似的。

如果您使用 Apache 中嵌入的 mod_wsgi，请注意 Apache 是多线程的，并且您的 Python 线程会合并到 Apache 的线程中。对阻塞的分析可能会变得很棘手。

如果您在守护进程模式下使用 mod_wsgi （您应该如此），那么您的 Django 是一个单独的进程。

为什么不继续这种设计模式并使您的“jabber 侦听器”成为一个单独的进程。

如果您希望此进程在任意多个服务器中运行，则可以从 init.rc 或 cron 启动它。

因为它是一个单独的过程，所以不会争夺注意力。您的 Django 进程运行速度很快，并且您的 Jabber 侦听器独立运行。

Answer 2

我已经成功地使用您描述的当前方法。通过阅读文档，您会发现扭曲的 DB api 在底层使用线程，因为大多数 SQL 库都有阻塞 API。

我有一个扭曲的服务器，用于保存现场电源监视器的数据，它通过时不时地启动一个子线程并调用我的 Django 保存代码来实现。您可以阅读有关我的实时数据的更多信息收集管道（这是一个博客链接）。

您是说您正在启动一个子线程，并且该子线程仍然处于阻塞状态吗？

Answer 3

我有一个正在运行的 Twisted 应用程序，我在其中使用 Django ORM。我不会推迟它。我知道这是错误的，但还没有任何问题。