הגדרת מעקב מבוזר למיקרוסרוויסים (Jaeger/Zipkin)

הערה: כאשר זמן האחזור p95 של שירות מיקרוסרוויס קופץ במפתיע ל-10 שניות והלוגים ב-Order Service נקיים לחלוטין — מתחיל מצוד הרפאים. במצבים כאלה, אנו מפעילים מעקב מבוזר: OpenTelemetry + Jaeger (או Zipkin) לראייה מלאה. מידע נוסף על מעקב מבוזר ניתן למצוא בויקיפדיה. כל בקשה משאירה שובל דיגיטלי על פני כל השירותים — מ-API Gateway ועד Payment Service — עם חותמות זמן. אתה רואה ש-80% מהזמן מושקע בשאילתת Elasticsearch אחת, לא בנעילה מבוזרת. לאחר היישום, לקוחות מצמצמים את זמן האבחון משלושה שבועות ליומיים — פי 3 מהר יותר. לקוח אחד השיג הפחתה משמעותית בעלויות השנתיות על ידי מזעור זמן השבתה. לקוח אחר עם 25 מיקרוסרוויסים קיצץ את זמן האבחון ב-70%.

אילו בעיות מעקב מבוזר פותר

מצב טיפוסי: שאילתת N+1 ב-Inventory Service הופכת את התגובה ל-5 שניות. או שמטמון Redis נכשל בגלל TTL שגוי — מעקב יראה החמצת מטמון. מעקב מבוזר חושף זמן בכל שירות, קריאות DB (PostgreSQL, MongoDB), API חיצוניים, והעברת קונטקסט. אתה רואה ש-80% מהזמן הולך לשאילתת Elasticsearch אחת, לא לנעילה מבוזרת. אנו מגדירים מעקב כדי לזהות צווארי בקבוק בשעות, לא בשבועות. דוגמה קונקרטית: עבור לקוח עם 15 מיקרוסרוויסים, מעקב מבוזר הראה ש-40% מהבקשות נתקעו בגלל timeout שגוי ב-HTTP client. התיקון לקח שעתיים במקום שבוע של ניחושים.

למה OpenTelemetry הוא התקן דה-פקטו?

OpenTelemetry (OTel) הוא SDK נייטרלי-ספק שמאפשר לשלוח מעקבים לכל backend ללא שינויי קוד. אנו משתמשים בו בכל הפרויקטים: משלבים פעם אחת, ואז בוחרים Jaeger לפיתוח, Datadog לייצור — ללא שכתוב. התמיכה כיום מכסה 20+ שפות ואינטגרציות. בהשוואה ל-SDK קנייניים, OpenTelemetry מקצר את זמן האינטגרציה פי 2 ומפשט הגירה בין backends. הניסיון שלנו בעשרות פרויקטים מאשר את אמינות הגישה הזו.

איך ליישם OpenTelemetry ב-Node.js: שלב אחר שלב

1. התקן חבילות: npm install @opentelemetry/sdk-node @opentelemetry/auto-instrumentations-node @opentelemetry/exporter-trace-otlp-http.
2. צור קובץ tracing.ts (ייבוא ראשון).
3. הגדר exporter: ציין כתובת Jaeger או backend אחר.
4. הוסף auto-instrumentations עבור HTTP, Express, PostgreSQL, Redis וכו'.
5. הפעל SDK עם sdk.start().

דוגמת אתחול עבור Order Service:

// tracing.ts — инициализация, импортировать до всего остального import { NodeSDK } from '@opentelemetry/sdk-node'; import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node'; import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-http'; import { Resource } from '@opentelemetry/resources'; import { SEMRESATTRS_SERVICE_NAME } from '@opentelemetry/semantic-conventions'; const sdk = new NodeSDK({ resource: new Resource({ [SEMRESATTRS_SERVICE_NAME]: 'order-service', }), traceExporter: new OTLPTraceExporter({ url: process.env.OTEL_EXPORTER_OTLP_ENDPOINT || 'http://jaeger:4318/v1/traces', }), instrumentations: [ getNodeAutoInstrumentations({ '@opentelemetry/instrumentation-http': { enabled: true }, '@opentelemetry/instrumentation-express': { enabled: true }, '@opentelemetry/instrumentation-pg': { enabled: true }, '@opentelemetry/instrumentation-redis': { enabled: true }, }), ], }); sdk.start(); 

Auto-instrumentations מיירטים Express, pg, redis, axios ללא כתיבת קוד.

יצירת Span ידנית

עבור פעולות עסקיות שאינן מכוסות על ידי auto-instrumentation:

import { trace, SpanStatusCode, context } from '@opentelemetry/api'; const tracer = trace.getTracer('order-service'); async function processOrder(orderId: string): Promise<void> { const span = tracer.startSpan('processOrder', { attributes: { 'order.id': orderId, 'service.operation': 'process' } }); try { await context.with(trace.setSpan(context.active(), span), async () => { const order = await loadOrder(orderId); // дочерний span создаётся авто await validateOrder(order); await reserveInventory(order); // вызов другого сервиса с propagation await chargePayment(order); }); span.setStatus({ code: SpanStatusCode.OK }); } catch (error) { span.recordException(error); span.setStatus({ code: SpanStatusCode.ERROR, message: error.message }); throw error; } finally { span.end(); } } 

איך לבחור Backend: Jaeger או Zipkin?

לפרויקטים חדשים — Jaeger. Zipkin אם כבר בשימוש או נדרשת תאימות. Jaeger מהיר פי 1.5–2 בממוצע לפריסה ומספק לוחות מחוונים מפורטים יותר. אנו מבטיחים שה-backend הנבחר ישולב בצורה אופטימלית בתשתית שלך.

איך להגדיר דגימה תחת עומס?

מפרט OpenTelemetry ממליץ על דגימה מבוססת ראש (head-based) למערכות בעומס גבוה.

דוגמה להגדרת דגימה מבוססת ראש עם OpenTelemetry:

import { ParentBasedSampler, TraceIdRatioBased } from '@opentelemetry/sdk-trace-base'; const sampler = new ParentBasedSampler({ root: new TraceIdRatioBased(0.1) }); 

זה עוקב אחר 10% מהבקשות, אבל תמיד אם ההורה כבר במעקב.

processors: tail_sampling: decision_wait: 30s num_traces: 100 expected_new_traces_per_sec: 10 policies: - name: sample_errors type: status_code properties: status_codes: [ERROR] - name: sample_slow type: latency properties: threshold_ms: 500 

מה כלול בהקמת מעקב?

אנו מספקים:

• בחירה ופריסה של backend (Jaeger/Zipkin) עם אחסון (Elasticsearch/Cassandra)
• אינטגרציה של OpenTelemetry SDK עם auto-instrumentations לכל השירותים
• אינסטרומנטציה ידנית של פעולות עסקיות קריטיות
• הגדרת העברת קונטקסט דרך כותרות HTTP (W3C Trace Context)
• הגדרת דגימה תחת עומס
• תיעוד תפעולי ולוחות מחוונים של Grafana
• הדרכת צוות על עבודה עם מעקבים

לוחות זמנים משוערים

• OpenTelemetry SDK + Jaeger + auto-instrumentations עבור 3–5 שירותים: 3–5 ימים
• אינסטרומנטציה ידנית של פעולות עסקיות + הגדרת דגימה: 3–5 ימים נוספים
• הגדרת התראות על p95 latency דרך Prometheus + Grafana: 2–3 ימים

קבל ייעוץ מהנדס — אנו// tracing.ts — инициализация, импортировать до всего остального import { NodeSDK } from '@opentelemetry/sdk-node'; import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node'; import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-http'; import { Resource } from '@opentelemetry/resources'; import { SEMRESATTRS_SERVICE_NAME } from '@opentelemetry/semantic-conventions'; const sdk = new NodeSDK({ resource: new Resource({ [SEMRESATTRS_SERVICE_NAME]: 'order-service', }), traceExporter: new OTLPTraceExporter({ url: process.env.OTEL_EXPORTER_OTLP_ENDPOINT || 'http://jaeger:4318/v1/traces', }), instrumentations: [ getNodeAutoInstrumentations({ '@opentelemetry/instrumentation-http': { enabled: true }, '@opentelemetry/instrumentation-express': { enabled: true }, '@opentelemetry/instrumentation-pg': { enabled: true }, '@opentelemetry/instrumentation-redis': { enabled: true }, }), ], }); sdk.start(); נקבל תמונה מלאה של ביצועי המיקרוסרוויסים. צור קשר כדי להעריך את הפרויקט שלך וללמוד כיצד מעקב מבוזר יקצר את זמן הדיבאג במערכת שלך.