הערה: כאשר עוקבים אחרי 500+ ארנקים דרך RPC ציבורי, זמן האחזור יכול להגיע ל-10 דקות. אותות מסחריים דורשים תגובה בשניות — ההבדל בין "הארנק קנה עכשיו טוקן X" לבין "קנה לפני 5 דקות" עולה 30% מפוטנציאל העסקה. פיתחנו מערכת שמפחיתה את הפיגור ל-2–3 שניות: מסיווג כתובות ועד התראות בזמן אמת. הניסיון שלנו מראה שהגדרה נכונה תופסת 90% מהמהלכים המשמעותיים לפני דיון ציבורי. בינתיים, עלויות התשתית הן $50–100 לחודש — פי 3 זול יותר מפתרונות מוכנים כמו Nansen או Arkham. בואו נפרק מה בדיוק דרוש לסינון כסף חכם — מתיוג היוריסטי ועד צינורות ייצור על webhooks. בפרויקט טיפוסי עם 1000 כתובות ו-5000 עסקאות ביום, אנו משיגים זמן אחזור מתחת ל-2 שניות באמצעות שילוב של webhooks וקאשינג.
סיווג ארנקי כסף חכם
אין מרשם יחיד לכסף חכם. אלה ארנקים שהתנועות שלהם נושאות ערך מידע גבוה: משקיעים מוקדמים, סוחרי לווייתנים, קרנות עם רקורד מוכח, כתובות של פרוטוקולים ידועים. מקורות לבניית הרשימה:
- ייחוס על-שרשרת: תוויות Etherscan (זמינות ב-API), Arkham Intelligence (חלקית ציבורית), Nansen (בתשלום, אך ניתן לייצא תוויות), לוחות מחוונים של Dune Analytics עם תוויות קהילה.
- סיווג היוריסטי: ארנקים שקונים באופן קבוע טוקנים לפני עלייה של פי 10, ROI גבוה על פני 12 חודשים על סמך נתוני על-שרשרת, משתתפים מוקדמים ב-IDO/ICO מצליחים.
interface WalletProfile {
address: string
labels: string[] // ['vc', 'early-investor', 'dex-whale']
chain: string
firstTx: Date
totalTxCount: number
watchPriority: 'high' | 'medium' | 'low'
source: string // откуда пришёл в список
}הרשימה הראשונית נאספת דרך:
- מחזיקי Top-N של טוקנים מרכזיים (טוקני ממשל של Uniswap, AAVE, Compound)
- משתתפים בסבבים מוקדמים (ניתוח אירועי Transfer מארנקי VC)
- שירותים מקצועיים: עדכון Nansen Smart Money, מעקב ישויות של Arkham
| מקור | זמינות | איכות נתונים | מהירות |
|---|---|---|---|
| Etherscan API | חינם (עד 5 בקשות/שנייה) | בינוני (תוויות קהילה) | מהיר |
| Nansen Smart Money | בתשלום ($100/חודש) | גבוה | מהיר |
| Arkham Intelligence | חלקית ציבורית | גבוה | מהיר |
| Dune Analytics | חינם (עם מגבלות) | בינוני (תלוי בלוח המחוונים) | בינוני |
למה ניטור בזמן אמת הוא קריטי
נתונים היסטוריים טובים לבדיקת ביצועים לאחור, אך אותות מסחריים דורשים תגובה מיידית. ההבדל בין "הארנק קנה עכשיו טוקן X" לבין "קנה לפני 5 דקות" יכול לעלות 30% מפוטנציאל העסקה. זרימה בזמן אמת בנויה על webhooks במקום בקשות פולינג — זה מפחית עומס וזמן אחזור. אנו משתמשים ב-Alchemy Notify — הוא עולה על Moralis Streams במהירות אספקה פי 2–3 ומציע אימות חתימה מובנה. לאחסון העברות, אנו משתמשים ב-TimescaleDB עם hypertables — זה מספק הכנסה מהירה פי 5 מ-PostgreSQL סטנדרטי עם חלוקה ידנית.
// Подписка через Alchemy Notify API
async function subscribeToWalletActivity(wallets: string[]): Promise<void> {
const payload = {
network: 'ETH_MAINNET',
webhook_type: 'ADDRESS_ACTIVITY',
webhook_url: `${process.env.APP_URL}/webhooks/alchemy`,
addresses: wallets,
}
const res = await fetch('https://notify.alchemyapi.io/dashboard/webhook-subscriptions', {
method: 'POST',
headers: {
'X-Alchemy-Token': process.env.ALCHEMY_NOTIFY_KEY!,
'Content-Type': 'application/json',
},
body: JSON.stringify(payload),
})
console.log('Webhook registered:', await res.json())
}
// Обработчик входящего webhook
app.post('/webhooks/alchemy', async (req, res) => {
const { event } = req.body
// Верификация подписи
const signature = req.headers['x-alchemy-signature']
if (!verifyAlchemySignature(req.rawBody, signature)) {
return res.status(401).send()
}
await processWalletActivity(event)
res.status(200).send()
}) איך לאסוף נתונים בזמן אמת?
העברות גולמיות אינן אות. יש צורך בפרשנות. איסוף הנתונים מתרחש דרך webhooks של Alchemy Notify, השולחים אירועי ADDRESS_ACTIVITY. כל אירוע מכיל פרטים: כתובת, טוקן, סכום, סוג עסקה. לאחר מכן הצינור מנתח דפוסים.
מה מספק ניתוח דפוסים?
הניתוח כולל מספר שלבים:
- איסוף כל ההעברות הנכנסות ב-24 השעות האחרונות.
- החרגת טוקנים שהיו בארנק יותר מ-24 שעות.
- שמירת טוקנים שנרכשו על ידי לפחות שלושה ארנקי כסף חכם.
- סינון עסקאות עם החלפות DEX (hash של נושא אירוע Swap).
-- Новые токен-позиции за последние 24 часа -- (токены, которых не было в кошельке 24ч назад, но есть сейчас)
WITH yesterday_holdings AS (
SELECT DISTINCT wallet, token_contract
FROM wallet_transfers
WHERE direction = 'in' AND block_time < NOW() - INTERVAL '24 hours'
),
new_buys AS (
SELECT t.wallet, t.token_contract, SUM(t.amount) as total_in
FROM wallet_transfers t
LEFT JOIN yesterday_holdings y ON t.wallet = y.wallet AND t.token_contract = y.token_contract
WHERE t.direction = 'in' AND t.block_time >= NOW() - INTERVAL '24 hours' AND y.token_contract IS NULL -- не было раньше
GROUP BY t.wallet, t.token_contract
)
SELECT nb.token_contract, COUNT(DISTINCT nb.wallet) AS smart_money_buyers, STRING_AGG(nb.wallet, ',') AS buyer_list
FROM new_buys nb
GROUP BY nb.token_contract
HAVING COUNT(DISTINCT nb.wallet) >= 3 -- минимум 3 smart money кошелька
ORDER BY smart_money_buyers DESCאותות נוספים: צבירה (רכישות חוזרות ללא מכירות), העברות גדולות לבורסות (מכירה סבירה), פעילות בשעות הראשונות לאחר רישום טוקן חדש.
| סוג אות | תיאור | סף הפעלה |
|---|---|---|
| פוזיציה חדשה | טוקן הופיע בארנק בפעם הראשונה ב-24 שעות | ≥3 ארנקי כסף חכם |
| צבירה | רכישות חוזרות ללא מכירות במשך 7 ימים | >50% עלייה ביתרה |
| מעבר לבורסה | העברה לכתובת CEX | כל נפח |
| נפח חריג | העברה בודדת > 2 סטיות תקן | יחסית לממוצע 30 יום |
מקרה בוחן
פרויקט אחד דרש ניטור של 300+ ארנקים ב-Ethereum ו-Polygon. קריאות RPC ישירות נתנו זמן אחזור של 5–8 דקות לסריקה מלאה. מעבר ל-Alchemy Asset Transfers + webhooks הפחית את זמן האחזור ל-2–3 שניות. בנוסף, יישמנו סיווג עסקאות לפי פרוטוקולי DEX — סינון של 40% מתוצאות חיוביות שגויות הקשורות להעברות פנימיות. החיסכון בתשתית הסתכם ב-$15,000 לשנה על ידי ביטול APIs חיצוניים יקרים (Nansen, Arkham). בעוד שמנוי Nansen עולה מ-$100/חודש, החלפנו אותו בשילוב של כלים חינמיים, וקיצצנו עלויות בחצי.
מה כלול ביישום
- הרכבת רשימת כסף חכם: מקורות (Nansen, Arkham, Etherscan, Dune) + היוריסטיקות, בסך הכל 500–2000 כתובות.
- כתיבת סקריפטים לאיסוף: נתונים היסטוריים דרך Alchemy Asset Transfers ו-RPC, בזמן אמת דרך webhooks.
- פריסת מסד נתונים: TimescaleDB לאחסון העברות ומטא-דאטה.
- הגדרת התראות: בוט Telegram / Slack עם סינון אותות.
- לוח מחוונים וניתוח SQL: דוחות על צבירה, פוזיציות חדשות, מעברים לבורסות.
- תיעוד והדרכה: תיאור ארכיטקטורה, API, דוגמאות שאילתות.
מידע נוסף: ארכיטקטורת מסד נתונים
אנו משתמשים ב-TimescaleDB עם מבנה חלוקה מבוסס זמן (hypertables) לאחסון העברות. זה מבטיח הכנסה מהירה ואגרגציה על פני כל תקופה. אינדקסים על interface WalletProfile { address: string labels: string[] // ['vc', 'early-investor', 'dex-whale'] chain: string firstTx: Date totalTxCount: number watchPriority: 'high' | 'medium' | 'low' source: string // откуда пришёл в список } מאיצים שאילתות כמו "פוזיציות חדשות".
אנו מבטיחים מומחיות: מעל 5 שנים בפיתוח בלוקצ'יין, 30+ פרויקטים של ניתוח על-שרשרת. נעריך את התרחיש שלך — צור קשר כדי לדון בפרטים. בקש ייעוץ, ונמצא את הפתרון האופטימלי לתקציב שלך.







