Wat is een partition in Kafka? Wat is een consumer group?
Python
Welke soorten en typen softwaretesten bestaan er?
FastAPI maakt het mogelijk om functies zowel asynchroon als synchroon te implementeren — hoe beïnvloedt dit het gedrag? Hoe kun je verzoeken paralleliseren in een async-functie?
Bekijk de functie count_pairs. Wat is de complexiteit ervan? Schrijf een efficiëntere versie.
Vertel me over het Saga-patroon. Hoe hebben jullie het geïmplementeerd? Hoe informeerden jullie de services over de rollback?
Schrijf een Dockerfile voor een Python-toepassing die het volgende doet: - Gebruikt de nieuwste Python-afbeelding - Stelt de werkdirectory in op /app - Kopieert de inhoud van de huidige directory naar de container - Installeert de dependencies vermeld in requirements.txt - Stelt poort 8000 open - Voert de applicatie uit met het commando: python app.py
Waarom is encapsulatie nodig? Welke risico's zijn er bij directe toegang tot de gegevens van het object?
Wat is encapsulatie? Welke kenmerken zijn er vanuit het oogpunt van Python?
Hoe maak je een datastructuur waarin je geen waarden kunt invoegen of wijzigen, maar wel op sleutel kunt opvragen?
# Hoe lang duurt het voordat asyncio.run(main()) wordt uitgevoerd?
broker = KafkaBroker("localhost:9092") app = FastStream(broker) @broker.subscriber("raw_texts_topic", group_id="text_parsers") async def handle_text(text_data: dict): # Parsing en opslaan in de database duurt ongeveer 10 seconden parse_text_and_save_to_postgres(text_data)
Hoe om te gaan met een blokkerende functie uit een oude bibliotheek zodat de event loop niet wordt geblokkeerd?
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): # Parsing van een bestand dat 5 minuten duurt 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"}
Wat is het object dat wordt geretourneerd door een functie met `yield`, en welke return type annotatie is hier geschikt in plaats van `list[str]`?
Vertel ons iets over jezelf en je technische ervaring.
Hoe heet het patroon waarbij `Engine` eenmaal voor de applicatie wordt gemaakt en een gedeelde connectiepool beheert?
Wat gebeurt er als de Kafka consumer pod crasht tijdens het verwerken van het bericht voordat de offset is bevestigd?
Wat is REST API?
Wat zijn de voordelen van een modulaire monoliet vergeleken met microservices in zo'n situatie?