django - 使用来自 django 应用程序的 kafka 消息

Question

我正在设计一个基于 django 的 Web 应用程序，该应用程序能够通过需要从 Kafka 主题中使用的 Web 套接字数据提供服务。

这时，我想出了一个分为两个组件的解决方案:一个组件从 kafka 中消费，对检索到的数据执行一些基本操作，并使用 http 请求将结果发送到 django 应用程序。
收到请求后，将通过特定的 django channel 写入消息。

有没有更好的架构来解决这种情况？我应该将所有 Kafka 部分都包含在 celery 异步任务中的“while True”循环中吗？我应该在 Django 启动时生成一个新进程吗？如果是这样，我还可以使用 django 信号通过网络套接字发送数据吗？

谢谢，
Facebook

Answer 1

是的，您可以使用 django 代码/存储库并构建单独的应用程序/程序来通过 django ORM 处理 kafka 队列和数据库

只需在此程序代码的开头添加

sys.path.append(os.getcwd())
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "<your_app>.settings")
django.setup()

然后你可以在这个程序中使用你的模型，比如

from <your_app>.models.timeslots import TimeSlotReserve

另外一个好主意是向这个单独的应用程序添加一些多线程