gyorsapi-ból importál FastAPI, UploadFile, Response fastapi válaszokból import StreamingResponse pydantic-ból importál BaseModel, field_validator import base64 app = FastAPI() class PdfSchema(BaseModel): filename: str content_type: str data: str # base64 pdf 10mb @app.get("/data", response_model=PdfSchema) async def get_data(): return await service.get_big_data() @app.get("/download") async def download(): with open("big.pdf", "rb") as f: data = f.read() return Response(content=data, media_type="application/pdf") def heavy_pdf_parse(data: bytes) -> dict: # CPU-heavy logika return {"size": len(data)} @app.post("/parse") async def parse(file: UploadFile): content = await file.read() result = heavy_pdf_parse(content) return result @app.get("/users") async def get_users(): users = await repo.get_users() result = [] for u in users: posts = await repo.get_posts(u["id"]) result.append({"user": u, "posts": posts}) return result @app.get("/download-two") async def download_two(): def iterfile(): with open("big.pdf", "rb") as f: yield from f return StreamingResponse(iterfile(), media_type="application/pdf") class service: @staticmethod async def get_big_data(): return { "filename": "file.pdf", "content_type": "application/pdf", "data": base64.b64encode(b"fake").decode(), } class repo: @staticmethod async def get_users(): return [{"id": 1}, {"id": 2}] @staticmethod async def get_posts(user_id: int): return [{"id": 1, "user id": user_id}]
Python
Ki állította be a riasztásokat, és hogyan alakul át a szolgáltatás kiesése riasztássá?
Találd meg azt a szimbólumot, amely a legtöbbször fordul elő egymás után a szövegben
Mi az a generátor? Mire használják Pythonban?
Milyen típusosság van Pythonban?
SQL feladat: hogyan lehet kinyerni a cirill és latin betűs nevekkel rendelkező felhasználókat úgy, hogy a cirill legyen az első, és a csoportokon belül lexikografikus sorrendben?
Mi az a Dockerfile és mire való?
Hogyan épülnek fel a lebegőpontos számok (float)?
Hogyan néz ki a folyamat a commit-től a tesztkörnyezetekre való telepítésig?
Milyen típusú HTTP-kérések alkalmasak a szerver vagy kliens oldali gyorsítótárazásra?
Mesélj a folyamatokról, szálakról és az aszinkronitásról Pythonban. Miben különböznek?
Mesélj a PostgreSQL tranzakciók izolációs szintjeiről és arról, hogy mire szolgálnak.
Hogyan történnek a JOIN-ok PostgreSQL oldalán? Milyen stratégiák léteznek?
Mi az a deadlock (akadály)?
Hogyan kezeljük egy régi könyvtárból származó blokkoló funkciót úgy, hogy ne blokkolja az eseményhurkot?
Mi az a partíció (partition) a Kafka-ban? Mi az a consumer group?
Mesélj a Magnit technikailag összetett dolgairól. Mi volt ott érdekes?
Mennyi időbe telik N különböző, K hosszúságú sztring beszúrása egy halmazba?
Az SQL-optimalizációs feladatok a termelésben felmerült problémák miatt jelentek meg, vagy te kezdeményezted őket?
import threading import time szamlalo = 0 def novel(): global szamlalo for _ in range(100): aktualis = szamlalo time.sleep(0.000001) szamlalo = aktualis + 1 thread1 = threading.Thread(target=novel) thread2 = threading.Thread(target=novel) thread1.start() thread2.start() thread1.join() thread2.join() print(f"Végső érték: {szamlalo}") 150-200