Как использовать KafkaConsumer с Django4

У меня есть проект Django 4 и я использую KafkaConsumer из kafka-python. Я хочу обновлять модели django после получения сообщения из Kafka. Цель состоит в том, чтобы иметь некий Kafka worker, работающий и потребляющий сообщения, он также должен иметь доступ к моделям в существующем приложении django ASGI. Возможно ли это или этот рабочий должен быть отдельным проектом django?

Да, это возможно. Вы можете просто написать скрипт на python и импортировать модель следующим образом

from PROJECT_PATH import settings as PROJECT
from django.core.management import settings

# Import your django model
from SOME_APP.models import SOME_MODEL

# import Kafka consumer 
from kafka import KafkaConsumer, TopicPartition

# Create kafka consumer
consumer = KafkaConsumer("topicName", bootstrap_servers='<BOOTSTRAP_SERVER>')
for msg in consumer:
    # play with message and use Django model here
Вернуться на верх