ניטור DeFi בזמן אמת: ארכיטקטורה ואבטחה

לאחר פריסת חוזה חכם, העבודה האמיתית מתחילה: צריך להבין מה קורה איתו בזמן אמת. ראינו פרויקטים ללא ניטור—וזה הוביל לאובדן כספים. ללא מערכת מדדים על-רשת, מגלים על בעיה רק כשמשתמשים מתחילים להתלונן, בעוד התוקף כבר רוקן את הנזילות. ניטור מדדים על-רשת אינו מותרות אלא הכרח לכל פרויקט DeFi עם TVL מעל מיליון דולר. במאמר זה, אשתף ניסיון אמיתי בהקמת מערכת כזו ואספק קוד מוכן לשימוש שתוכלו להתאים לחוזים שלכם.

"ניטור על-רשת בזמן אמת הוא קו ההגנה הראשון לכל פרוטוקול DeFi." — אומרים המהנדסים שלנו עם ניסיון על למעלה מ-100 פרויקטים.

אנו משתמשים בסטACK: Ethereum (באמצעות viem עם WebSocket), Prometheus + Alertmanager, Grafana, TimescaleDB. כל הרכיבים מנוסים בייצור בפרויקטים עם TVL מעל 10 מיליון דולר. המערכת שלנו מעבדת עד 2,000 אירועים בשנייה—מספיק לכל פרוטוקול DeFi. יש לנו מעל 5 שנות ניסיון בפיתוח בלוקצ'יין, וביצענו יותר מ-50 פרויקטי ניטור DeFi.

אילו מדדים על-רשת חשובים ל-DeFi?

קבוצות מדדים עיקריות

מדדים תפעוליים: תדירות קריאה לפונקציות מפתח, צריכת גז לפי מתודה (גידול חריג עשוי להצביע על פעולות יקרות או התקפה), יחס עסקאות שנכשלו (עלייה מעל 10% מפעילה התראה), TVL.

מדדים עסקיים: DAU/MAU על-רשת (כתובות ייחודיות לתקופה), שימור—כתובות שחוזרות לאחר N ימים, נפח בדולרים דרך פונקציות ספציפיות, כתובות N המובילות לפי פעילות (גלאי התראות על לווייתנים).

אבטחה: משיכות גדולות, דפוסי קריאה חריגים (flash loan + חוזה באותו בלוק), שינויי תפקידי מנהל, קריאות מכתובות חדשות עם יתרה גדולה.

למה ניטור בזמן אמת הוא קריטי?

אנומליה שהוחמצה יכולה לעלות מיליונים. דוגמה מהפרקטיקה שלנו: ה-TVL של לקוח ירד לפתע ב-30% תוך שעה. ללא ניטור, הצוות גילה זאת רק יום לאחר מכן דרך טוויטר. התברר שתוקף השתמש ב-flash loan כדי לתמרן את המחיר. הגדרנו התראה על ירידה חדה ב-TVL—כעת אירועים כאלה מתגלים תוך דקות. מדדים על-רשת הם העיניים של הפרוטוקול שלכם.

ארכיטקטורת מערכת ניטור מדדים על-רשת

מקורות נתונים

יומני אירועים הם הדרך המהירה והזולה ביותר לקבלת נתונים (רישום אירועים). הם מספקים זמן השהיה מתחת ל-500 אלפיות השנייה, מהיר פי 20 מ-Dune Analytics. אם החוזה שלכם לא פולט אירועים נדרשים—הוסיפו אותם (אם ניתן לשדרג) או השתמשו בקריאות trace.

תרשים זרימה

 ┌─────────────────┐ │ Blockchain RPC │ │ (Alchemy/own) │ └────────┬────────┘ │ eth_getLogs / WebSocket ┌────────────▼──────────────┐ │ Event Collector │ │ (подписка на контракт) │ └────────────┬──────────────┘ │ ┌────────────▼──────────────┐ │ Metrics Processor │ │ Декодирование ABI, │ │ агрегация, enrichment │ └──────┬────────────┬────────┘ │ │ ┌────────────▼──┐ ┌──────▼──────────────┐ │ TimescaleDB │ │ Prometheus/VictoriaDB│ │ (история) │ │ (реалтайм метрики) │ └───────────────┘ └──────────────────────┘ │ ┌─────────▼──────────┐ │ Grafana Dashboard │ │ + Alertmanager │ └────────────────────┘ 

יישום טכני

קולט אירועים ב-viem

import { createPublicClient, webSocket, parseAbiItem, decodeEventLog } from 'viem'; import { mainnet } from 'viem/chains'; const client = createPublicClient({ chain: mainnet, transport: webSocket('wss://eth-mainnet.g.alchemy.com/v2/YOUR_KEY'), }); const CONTRACT_ABI = [ parseAbiItem('event Deposit(address indexed user, uint256 amount)'), parseAbiItem('event Withdraw(address indexed user, uint256 amount)'), parseAbiItem('event Swap(address indexed user, address tokenIn, address tokenOut, uint256 amountIn, uint256 amountOut)'), ]; const unwatch = client.watchContractEvent({ address: CONTRACT_ADDRESS, abi: CONTRACT_ABI, onLogs: async (logs) => { for (const log of logs) { await processEvent(log); } }, onError: (error) => { console.error('WS error, reconnecting...', error); }, }); async function processEvent(log: any) { const decoded = decodeEventLog({ abi: CONTRACT_ABI, ...log }); await db.query(` INSERT INTO contract_events (time, block_number, tx_hash, event_name, user_address, amount_usd) VALUES (NOW(), $1, $2, $3, $4, $5) `, [log.blockNumber, log.transactionHash, decoded.eventName, decoded.args.user, await convertToUSD(decoded.args.amount)]); eventCounter.labels(decoded.eventName).inc(); } 

מדדי Prometheus והתראות

import { Counter, Gauge, Registry } from 'prom-client'; const registry = new Registry(); const eventCounter = new Counter({ name: 'contract_events_total', help: 'Total contract events by type', labelNames: ['event_name'], registers: [registry], }); const tvlGauge = new Gauge({ name: 'contract_tvl_usd', help: 'Total Value Locked in USD', registers: [registry], }); const largeWithdrawalCounter = new Counter({ name: 'contract_large_withdrawals_total', help: 'Withdrawals above threshold', labelNames: ['threshold_category'], registers: [registry], }); app.get('/metrics', async (req, res) => { res.set('Content-Type', registry.contentType); res.send(await registry.metrics()); }); 

groups: - name: contract_security rules: - alert: LargeWithdrawal expr: rate(contract_large_withdrawals_total[5m]) > 0 for: 0m labels: severity: critical annotations: summary: "Large withdrawal detected" - alert: HighFailureRate expr: | rate(contract_failed_txns_total[10m]) / rate(contract_total_txns_total[10m]) > 0.1 for: 5m annotations: summary: "More than 10% of transactions failing" - alert: TVLDrop expr: | (contract_tvl_usd - contract_tvl_usd offset 1h) / contract_tvl_usd offset 1h < -0.2 for: 2m annotations: summary: "TVL dropped by more than 20% in 1 hour" 

-- Ежедневные активные пользователи SELECT date_trunc('day', time) AS day, COUNT(DISTINCT user_address) AS dau, SUM(amount_usd) AS volume_usd FROM contract_events WHERE event_name IN ('Deposit', 'Swap') GROUP BY 1 ORDER BY 1 DESC; -- Retention: пользователи вернувшиеся через 7 дней WITH first_use AS ( SELECT user_address, MIN(time) AS first_time FROM contract_events GROUP BY 1 ), return_use AS ( SELECT DISTINCT e.user_address FROM contract_events e JOIN first_use f ON e.user_address = f.user_address WHERE e.time > f.first_time + INTERVAL '7 days' AND e.time < f.first_time + INTERVAL '14 days' ) SELECT COUNT(r.user_address)::float / COUNT(f.user_address) AS week1_retention FROM first_use f LEFT JOIN return_use r ON f.user_address = r.user_address;