Python

Berichten Sie über Ihre Erfahrung mit Kafka und FastStream

Wann können wir commit beim Producer aufrufen? Wie vermeidet man Duplikate beim manuellen Batch-Commit?

Es werden drei Tabellen bereitgestellt: 1. Benutzer (users): - id (eindeutige Benutzer-ID). - name (Benutzername). 2. Kurse (courses): - id (eindeutige Kurs-ID). - name (Name des Kurses). - price (Preis des Kurses). 3. Kurse der Studenten (student_courses): - id (Eintrags-ID). - student_id (Benutzer-ID). - course_id (Kurs-ID). Es wird benötigt: Alle Benutzer anzuzeigen, die Kurse im Wert von mehr als 10.000 gekauft haben, im Format: - user_name (Benutzername). - total_price (Gesamtsumme der Einkäufe). Startcode select * from users limit 10; select * from courses limit 10; select * from student_courses limit 10;

Kann man einen unendlichen Iterator und Generator erstellen? Was braucht man dafür?

Was tun mit einem problematischen Chunk, der ständig Ausnahmen bei der Verarbeitung verursacht? Wie nicht im Kreis laufen und weitergehen?

```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]: # gibt einen Datenblock oder None zurück ... async def commit(self, chunks: List[Chunk]) -> None: # bestätigt die erfolgreiche Verarbeitung der 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 ist zu groß") # Datenverarbeitung ... 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("Fehler, aber fortfahren:", e) continue if __name__ == "__main__": asyncio.run(process()) ```

Erzählen Sie mir von Dekoratoren in Python: Was ist dieses Muster und wie implementiert man einen Dekorator mit Argumenten?

Erklären Sie das Verhalten einer Funktion mit einem veränderlichen Standardargument. Was werden die Prints ausgeben?

Erzähl mir von einem deiner letzten Projekte, das dir im Herzen lag. Was war das für ein Projekt, was hast du genau dort gemacht und warum hat es dich berührt?

Liskov'sches Substitutionsprinzip — erzählen Sie mir mehr

Erzählen Sie mir von Ihrem aktuellen Team und den Projekten bei [Bank/Unternehmen]

Erzählen Sie uns von den Prinzipien der OOP: Kapselung, Vererbung, Polymorphismus, Abstraktion

Was wissen Sie über unser Unternehmen?

Erzählen Sie uns von der Verwendung von Dataclasses in Ihrem Projekt und warum Sie sie gewählt haben

Wie werden Sie zwischen mehreren Angeboten wählen? Was ist Ihnen wichtig?

Erzählen Sie uns von den SOLID-Prinzipien

wenn total_size > self.max_batch_size: raise ValueError("Chargung ist zu groß")