database - 如何从 Django 异步处理数据库写入(可能使用消息队列)？

Question

用户向我的应用提交数据后，我想写信给异步数据库，可能通过消息队列。

如何设置这样的系统？是否有任何可插入的 Django 应用程序进行这种基于消息队列的数据库写入？

另外，如何处理异步处理期间发生的错误？

如果您能给我任何建议，我将不胜感激。谢谢。

Answer 1

Celery作为后端有处理器的队列机制。这是更简单的设置之一，而且非常有效。您可以根据需要坚持或不坚持。有 a good walk through on setting it with django也在网站上。通常，您会将队列处理器作为守护进程运行，如果您正在使用这些模型位，则从 Django 导入模型位，并根据需要执行更新/插入/等操作。

文档包括 an example of processing a serial task您可以将其用作模板。