Papaskokite apie savo patirtį dirbant su Kafka ir FastStream
Python
Kada galime iškviesti commit Producer'yje? Kaip išvengti dubliavimo atliekant rankinį batch commit?
Pateikiamos trys lentelės: 1. Vartotojai (users): - id (unikalus vartotojo identifikatorius). - name (vartotojo vardas). 2. Kursai (courses): - id (unikalus kurso identifikatorius). - name (kurso pavadinimas). - price (kurso kaina). 3. Studentų kursai (student_courses): - id (įrašo identifikatorius). - student_id (vartotojo identifikatorius). - course_id (kurso identifikatorius). Reikalavimas: Parodyti visus vartotojus, kurie įsigijo kursų už daugiau nei 10 000, formatu: - user_name (vartotojo vardas). - total_price (bendras pirkimų suma). Pradinis kodas select * from users limit 10; select * from courses limit 10; select * from student_courses limit 10;
Ar įmanoma sukurti begalinį iteratorių ir generatorių? Ko tam reikia?
Ką daryti su problematišku gabalu, kuris nuolat sukelia išimtis apdorojimo metu? Kaip nepasiklysti ir eiti toliau?
```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]: # маалыматтардын партиясын же None кайтарат ... async def commit(self, chunks: List[Chunk]) -> None: # ийгиликтүү иштетүүнү тастыктоо ... 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("партия өтө чоң") # маалыматтарды иштетүү ... 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("каталар, бирок улантабыз:", e) continue if __name__ == "__main__": asyncio.run(process()) ```
Papaskinkite apie dekoratorius Python: kas tai už modelis ir kaip įgyvendinti dekoratorių su argumentais?
Paaiškinkite funkcijos elgesį su mutabiliuoju numatytuoju argumentu. Ką išves spausdinimai?
Liskovo pakaitumo principas — papasakokite išsamiau
Papaskink apie vieną iš savo paskutinių projektų, kuris palietė tavo širdį. Koks tai buvo projektas, ką tiksliai ten darėte ir kodėl jis tau palietė širdį?
Papaskinkite apie savo dabartinę komandą ir projektus [banke/įmonėje]
Papaskinkite apie OOP principus: inkapsuliacija, paveldėjimas, polimorfizmas, abstrakcija
Ką žinote apie mūsų įmonę?
Papaskinkite apie duomenų klasių naudojimą jūsų projekte ir kodėl jas pasirinkote
Kaip pasirinksite tarp kelių pasiūlymų? Kas jums svarbu?
Papaskinkite apie SOLID principus
jei total_size > self.max_batch_size: raise ValueError("partija per didelė")