Python

Cum funcționează `Depends(get_db)` în contextul unui endpoint FastAPI și de ce este necesar mecanismul de injecție a dependențelor?

broker = KafkaBroker("localhost:9092") app = FastStream(broker) @broker.subscriber("raw_texts_topic", group_id="text_parsers") async def handle_text(text_data: dict): # Analiza și salvarea în baza de date durează aproximativ 10 secunde parse_text_and_save_to_postgres(text_data)

# Cât timp durează pentru asyncio.run(main()) să se execute?

Care este obiectul returnat de o funcție cu `yield`, și ce adnotare de tip de returnează este potrivită aici în loc de `list[str]`?

def extract_emails_from_huge_file(file_path: str) -> list[str]: with open(file_path, 'r', encoding='utf-8') as f: content = f.read() # Înlocuim salturile de linie pentru ca textul să fie "fără întreruperi" content = content.replace('\r\n', ' ').replace('\n', ' ') lines = content.split(' ') emails = [word for word in lines if '@' in word] return emails

Cum să previi reprocesarea aceleiași mesaje Kafka? Unde și cum să organizezi verificarea idempotentei pe partea consumatorului?

Încă mai lucrezi la Toca?

Cum se aliniază experiența ta cu rolul de expert Python: lucrul cu framework-uri, programare asincronă și multiprocessing?

Ai întrebări despre compoziția echipei și planurile pentru formarea acesteia?

Cum ai realizat optimizarea bazei de date: folosind EXPLAIN/EXPLAIN ANALYZE, indexuri și restructurarea interogărilor?

Cât de profund ai pătruns în CI/CD și configurarea serviciilor?

Ce context, în afară de cererea de fuziune (MR), a fost transmis în prompturi pentru analiză?

Compania are acreditare IT și înregistrare conform Codului Muncii din RF?

Ce bază de date este utilizată pentru căutarea aproximativă?