Vertel over je ervaring met Kafka en FastStream
Python
Wanneer kunnen we commit aanroepen bij de Producer? Hoe voorkomen we dubbele records bij handmatige commit van een batch?
Er worden drie tabellen gegeven: 1. Gebruikers (users): - id (unieke gebruikers-ID). - name (gebruikersnaam). 2. Cursussen (courses): - id (unieke cursus-ID). - name (naam van de cursus). - price (prijs van de cursus). 3. Studenten cursussen (student_courses): - id (registratie-ID). - student_id (gebruikers-ID). - course_id (cursus-ID). Vereist: Toon alle gebruikers die cursussen hebben gekocht voor een bedrag van meer dan 10.000, in het formaat: - user_name (gebruikersnaam). - total_price (totaalbedrag van aankopen). Startcode select * from users limit 10; select * from courses limit 10; select * from student_courses limit 10;
Is het mogelijk om een oneindige iterator en generator te maken? Wat is er voor nodig?
Wat te doen met een problematische batch die voortdurend uitzonderingen veroorzaakt tijdens verwerking? Hoe blijf je niet hangen en ga je verder?
```python import asyncio from typing import List, Optional class Chunk: def __init__(self, items: List[dict]): self.items = items @property def size(self) -> int: return len(self.items) class Producer: async def next(self) -> Optional[Chunk]: # geeft een batch gegevens of None ... async def commit(self, chunks: List[Chunk]) -> None: # bevestigt succesvolle verwerking van chunks ... class Consumer: max_batch_size = 100 async def consume(self, chunks: List[Chunk]) -> None: total_size = sum(chunk.size for chunk in chunks) if total_size > self.max_batch_size: raise ValueError("batch is te groot") # gegevensverwerking ... producer = Producer() consumer = Consumer() async def process(): while True: chunk = await producer.next() if chunk is None: break try: await consumer.consume([chunk]) await producer.commit([chunk]) except Exception as e: print("fout maar ga door:", e) continue if __name__ == "__main__": asyncio.run(process()) ```
Vertel me over decorators in Python: wat voor patroon is dit en hoe implementeer je een decorator met argumenten?
Leg het gedrag uit van een functie met een mutable standaardargument. Wat zullen de prints tonen?
Vertel me over een van je laatste projecten die je heeft geraakt. Wat voor project was het, wat deed je er precies en waarom raakte het je?
Liskov Substitutieprincipe — vertel er meer over
Vertel me over je huidige team en projecten bij [bank/bedrijf]
Vertel over de principes van OOP: encapsulatie, overerving, polymorfisme, abstractie
Wat weet u over ons bedrijf?
Vertel over het gebruik van dataclasses in uw project en waarom u ze hebt gekozen
Hoe kiest u tussen meerdere aanbiedingen? Wat is voor u belangrijk?
als total_size > self.max_batch_size: raise ValueError("batch is te groot")
Vertel ons over de SOLID-principes