Qu'est-ce qu'une partition dans Kafka ? Qu'est-ce qu'un groupe de consommateurs ?
Python
Quels sont les types et catégories de tests logiciels?
FastAPI permet d'implémenter des fonctions à la fois asynchrones et synchrones : comment cela influence-t-il le comportement ? Comment paralléliser les requêtes dans une fonction async ?
Regarde la fonction count_pairs. Quelle est sa complexité ? Écris une version plus efficace.
Parlez-moi du pattern Saga. Comment l'avez-vous implémenté chez vous ? Comment informiez-vous les services du rollback ?
Écrivez un Dockerfile pour une application Python qui fait ce qui suit : - Utilise la dernière image Python - Définit le répertoire de travail sur /app - Copie le contenu du répertoire actuel dans le conteneur - Installe les dépendances listées dans requirements.txt - Expose le port 8000 - Exécute l'application en utilisant la commande : python app.py
Pourquoi l'encapsulation est-elle nécessaire ? Quels sont les risques d'accéder directement aux données de l'objet ?
Qu'est-ce que l'encapsulation ? Quelles sont les caractéristiques du point de vue de Python ?
Comment créer une structure de données dans laquelle il est impossible d'insérer ou de modifier des valeurs, mais où l'on peut accéder par clé?
# Combien de temps faut-il pour exécuter asyncio.run(main()) ?
broker = KafkaBroker("localhost:9092") app = FastStream(broker) @broker.subscriber("raw_texts_topic", group_id="text_parsers") async def handle_text(text_data: dict): # Analyse et sauvegarde dans la base de données prend environ 10 secondes parse_text_and_save_to_postgres(text_data)
Comment gérer une fonction bloquante d'une ancienne bibliothèque pour ne pas bloquer la boucle d'événements?
async def get_user(user_id: int, db: AsyncSession): try: user = await db.get(User, user_id) return user finally: await db.close() return None a = await get_user(15, db) # a?
app = FastAPI() def get_db(): db = SessionLocal() try: yield db finally: db.close() def heavy_text_parser(file_id: int, db: Session): # Analyse de fichier qui dure 5 minutes parse_and_save(file_id, db) @app.post("/upload") async def upload_file( background_tasks: BackgroundTasks, db: Session = Depends(get_db) ): file_id = save_file_to_db(db) db.commit() background_tasks.add_task(heavy_text_parser, file_id, db) return {"status": "parsing started"}
Quel est l'objet renvoyé par une fonction avec `yield`, et quelle annotation de type de retour est appropriée ici à la place de `list[str]`?
Parlez-nous un peu de vous et de votre expérience technique.
Comment s'appelle le pattern où `Engine` est créé une fois pour l'application et gère un pool de connexions partagé?
Que se passe-t-il si le pod du consommateur Kafka plante lors du traitement du message avant de valider le décalage ?
Qu'est-ce que l'API REST?
Quels sont les avantages d'un monolitique modulaire par rapport aux microservices dans une telle situation?