Erzählen Sie mir vom asynchronen Processing über Kafka: Welche Daten wurden übertragen, welche Schlüssel wurden verwendet, wie wurde die Reihenfolge der Verarbeitung sichergestellt?
Python
import threading import time zähler = 0 def inkrementieren(): global zähler for _ in range(100): aktuell = zähler time.sleep(0.000001) zähler = aktuell + 1 thread1 = threading.Thread(target=inkrementieren) thread2 = threading.Thread(target=inkrementieren) thread1.start() thread2.start() thread1.join() thread2.join() print(f"Endgültiger Zählerstand: {zähler}") 150-200
Erzähl mir von technisch komplexen Dingen bei Magnit. Was war dort interessant?
Erzähle mir von den Isolationsstufen von Transaktionen in PostgreSQL und wozu sie dienen.
Was passiert in asyncio.gather(), wenn in einer der Aufgaben ein Fehler auftritt? Wie kann man sicherstellen, dass Ausnahmen nicht verloren gehen?
Verwendest du die Programmiersprache Go bei deiner Entwicklung?
aus fastapi import FastAPI, UploadFile, Response from fastapi.responses import StreamingResponse from pydantic import BaseModel, field_validator import base64 app = FastAPI() class PdfSchema(BaseModel): filename: str content_type: str data: str # base64 pdf 10мб @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 логика 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}]
Erzähle mir von ACID. Besonders über die Isolationsstufen von Transaktionen. Welchen Grad haben sie verwendet?
Wie lange dauert es, N verschiedene Strings der Länge K in eine Menge einzufügen?
Systemkonfiguration und Schulung zum Ersetzen von Pinkman-Erwähnungen durch targetAI
Was sind EXPLAIN und EXPLAIN ANALYZE in PostgreSQL? Wie führt man DELETE/UPDATE durch, ohne tatsächliche Änderungen vorzunehmen?
Wie hast du herausgefunden, dass etwas kaputt geht oder degradiert? Worauf hast du geschaut?
Finde das Symbol, das in der Zeichenkette am häufigsten aufeinanderfolgend vorkommt
CREATE TABLE products ( id SERIAL PRIMARY KEY, category VARCHAR(100) NOT NULL, name VARCHAR(255) NOT NULL, description TEXT, price DECIMAL(10, 2) NOT NULL CHECK (price >= 0) );
In deinem Lebenslauf steht, dass du die Bearbeitung von Bestellungen von 3 Sekunden auf 50 Millisekunden durch die Auslagerung in Celery optimiert hast. Was genau hat die Verzögerung verursacht, wie hast du entschieden, was ausgelagert wird, und wie hast du das Ergebnis gemessen?
Auf welcher Grundlage wurde die Absicht bestimmt und wohin sollte der Benutzer in Ihrem Bot weitergeleitet werden?
Erzählen Sie mir vom GIN-Index. Warum wurde die Volltextsuche in PostgreSQL verwendet und nicht Elasticsearch?
Was ist ein Kontextmanager, wozu dient er und wie kann man seinen eigenen erstellen?
Warum haben Sie den GIN-Index für die Volltextsuche gewählt? Warum haben Sie keine Suchmaschinen wie Elasticsearch verwendet?
Worin besteht der Unterschied zwischen asyncio.create_task() und await coroutine? Wann wird eine Aufgabe ohne await ausgeführt?