
python 3.x – Comment créer un consommateur kafka indépendant du serveur Django
Je suis assez nouveau pour Python. J'ai une application Web basée sur Django dans laquelle j'effectue certaines tâches à l'aide de Kafka.
j'utilise confluent-kafka
wrapper pour communiquer avec le courtier Kafka.
Donc, une fois qu'un sujet est créé sur le kafka courtier, J'assigne un consommateur pour qu'il s'abonne à ce processus, pour qu'il soit non bloquant, j'utilise multitraitement
module afin que le consommateur s'exécute sur un thread séparé et ne bloque pas le thread principal de l'application.
Cependant, je ne suis pas sûr que se passera-t-il si mon serveur s'arrête? Le processus fonctionnera-t-il toujours de la même façon que les tâches cron, même si le serveur ne fonctionne pas?
Sinon, quelqu'un peut-il me suggérer comment déclencher mon consommateur pour qu'il soit indépendant de mon serveur Django?
Commentaires
Laisser un commentaire