python 3.x – Comment créer un consommateur kafka indépendant du serveur Django
Author: Titanfall —
Short summary: 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 […]
Quick overview
- Site
- Tutos GameServer
- Canonical URL
- https://tutos-gameserver.fr/2019/04/21/python-3-x-comment-creer-un-consommateur-kafka-independant-du-serveur-django/
- LLM HTML version
- https://tutos-gameserver.fr/2019/04/21/python-3-x-comment-creer-un-consommateur-kafka-independant-du-serveur-django/llm
- LLM JSON version
- https://tutos-gameserver.fr/2019/04/21/python-3-x-comment-creer-un-consommateur-kafka-independant-du-serveur-django/llm.json
- Manifest
- https://tutos-gameserver.fr/llm-endpoints-manifest.json
- Estimated reading time
- 1 minute (60 seconds)
- Word count
- 159
Key points
- 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.
Primary visual
Structured content
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?
Click to rate this post! [Total: 0 Average: 0]
Topics and keywords
Themes: Non classé
License & attribution
License: CC BY-ND 4.0.
Attribution required: yes.
Manifest: https://tutos-gameserver.fr/llm-endpoints-manifest.json
LLM Endpoints plugin version 1.1.2.