我正在设计一个基于django的web应用程序,它能够通过web套接字提供kafka主题中需要使用的数据。
此时,我提出了一个分为两个组件的解决方案:一个组件使用kafka提供的数据,对检索到的数据执行一些基本操作,并使用http请求将结果发送到django应用程序。在收到请求之后,一条消息会被写入特定的django通道。
有没有更好的架构来解决这种情况?我应该在celery 异步任务的“while true”循环中包含所有kafka部分吗?我应该在django启动时生成一个新进程吗?如果是这样,我还可以使用django信号通过websocket发送数据吗?
谢谢,fb
1条答案
按热度按时间mklgxw1f1#
是的,您可以使用您的django代码/存储库,并通过django orm构建单独的应用程序/程序来处理kafka队列和数据库
只需在这个程序的开头添加如下代码
然后你可以在这个程序中使用你的模型,比如
另外一个好主意是在这个单独的应用程序中添加一些多线程