如何從Django異步處理數據庫寫入（可能有消息隊列）？

Question

在用戶向我的應用程序提交數據後，我想通過消息隊列異步地寫入 數據庫。

如何設置這樣的系統？是否有可執行此類基於消息隊列的數據庫寫入的可插入Django應用程序 ？

另外我如何處理異步處理過程中發生的錯誤？

真的很感謝你能給我的任何指針。謝謝。

Answer 1

Celery作爲在後端具有處理器的隊列機制。這是更簡單的設置之一，非常有效。根據需要，您可以使用持久性來支持它，或者不使用它。網站上也有a good walk through on setting it with django。通常情況下，你會運行一個隊列處理器作爲守護進程，如果你正在使用這些模型位，則從Django導入模型位，並根據需要執行更新/插入/ etc。

該文檔包括您可以用作模板的an example of processing a serial task。

Answer 2

你可以看看Celery與RabbitMQ或另一ghetto queue。