Czym jest partycja w Kafka? Czym jest grupa konsumentów?
Python
Spójrz na funkcję count_pairs. Jaka jest jej złożoność? Napisz bardziej wydajną wersję.
Czy w Pod jest oddny system operacyjny?
Jakie istnieją rodzaje i typy testów oprogramowania?
Opowiedz o wzorcu Saga. Jak go zaimplementowaliście? Jak informowaliście serwisy o wycofaniu?
Czym jest enkapsulacja? Jakie cechy ma z punktu widzenia Pythona?
Napisz Dockerfile dla aplikacji Python, która: - Używa najnowszego obrazu Python - Ustawia katalog roboczy na /app - Kopiuje zawartość bieżącego katalogu do kontenera - Instaluje zależności wymienione w requirements.txt - Udostępnia port 8000 - Uruchamia aplikację za pomocą polecenia: python app.py
Po co jest potrzebna enkapsulacja? Jakie są ryzyko przy bezpośrednim dostępie do danych obiektu?
Jak stworzyć strukturę danych, do której nie można dodawać ani modyfikować wartości, ale można je odczytać po kluczu?
broker = KafkaBroker("localhost:9092") app = FastStream(broker) @broker.subscriber("raw_texts_topic", group_id="text_parsers") async def handle_text(text_data: dict): # Parsowanie i zapis do bazy danych zajmuje około 10 sekund parse_text_and_save_to_postgres(text_data)
# Ile czasu zajmuje wykonanie asyncio.run(main())?
Jak obsłużyć blokującą funkcję z starej biblioteki, aby nie blokować pętli zdarzeń?
app = FastAPI() def get_db(): db = SessionLocal() try: yield db finally: db.close() def heavy_text_parser(file_id: int, db: Session): # Parsowanie pliku, które trwa 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"}
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?
Jaki jest obiekt zwracany przez funkcję z `yield`, i jaka adnotacja typu zwrotu jest tutaj odpowiednia zamiast `list[str]`?
Opowiedz nam trochę o sobie i swoim doświadczeniu technicznym.
Jak nazywa się wzorzec, w którym `Engine` jest tworzony raz dla aplikacji i zarządza wspólnym pulą połączeń?
Co się stanie, jeśli pod konsumenta Kafka się zawiesi podczas przetwarzania wiadomości przed zatwierdzeniem przesunięcia?
Czym jest REST API?
Jakie są zalety modularnego monolitu w porównaniu do mikroserwisów w takiej sytuacji?