Co je to partition v Kafka? Co je to consumer group?
Python
Existuje v Pod samostatný operační systém?
Jaké existují druhy a typy testování softwaru?
Podívej se na funkci count_pairs. Jaká je její složitost? Napiš efektivnější verzi.
Pověz mi o vzoru Saga. Jak jste ho implementovali? Jak jste informovali služby o rollbacku?
Vytvořte Dockerfile pro Pythonovou aplikaci, která: - Používá nejnovější obraz Pythonu - Nastaví pracovní adresář na /app - Zkopíruje obsah aktuálního adresáře do kontejneru - Nainstaluje závislosti uvedené v requirements.txt - Otevře port 8000 - Spustí aplikaci pomocí příkazu: python app.py
Proč je potřeba zapouzdření? Jaká jsou rizika při přímém přístupu k datům objektu?
Co je to zapouzdření? Jaké jsou vlastnosti z pohledu Pythonu?
Jak vytvořit datovou strukturu, do které nelze vkládat ani měnit hodnoty, ale lze je získat podle klíče?
broker = KafkaBroker("localhost:9092") app = FastStream(broker) @broker.subscriber("raw_texts_topic", group_id="text_parsers") async def handle_text(text_data: dict): # Parsování a uložení do databáze trvá přibližně 10 sekund parse_text_and_save_to_postgres(text_data)
# Jak dlouho trvá spuštění asyncio.run(main())?
Jak zacházet s blokující funkcí z staré knihovny, aby nezablokovala událostní smyčku?
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): # Analýza souboru, která trvá 5 minut 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"}
Jaký je objekt vrácený funkcí s `yield`, a jaká návratová anotace je zde vhodná místo `list[str]`?
Řekněte nám něco málo o sobě a vaší technické zkušenosti.
Jak se nazývá vzor, kdy je `Engine` vytvořen jednou pro aplikaci a spravuje sdílený pool připojení?
Co se stane, pokud se pod Kafka spotřebitele zhroutí během zpracování zprávy před potvrzením offsetu?
Co je REST API?
Jaké jsou výhody modulárního monolitu ve srovnání s mikroservisy v takové situaci?