필드
| 분류 | 예시 |
|---|---|
| Identity | chainId, txHash, logIndex, blockNumber, timestamp |
| Parties | makerAddress, takerAddress, router, dex |
| Economics | tokenIn, tokenOut, amountIn, amountOut, priceUsd, sizeUsd |
| Context | poolAddress, feeTier, slippageBps, gasUsedUsd |
커버리지 & 신선도
- 지연: Kafka 1–2s, REST 5–10s.
- DEX: Uniswap v2/v3/v4, Raydium, Meteora, PancakeSwap, Aerodrome, Jupiter 라우팅 등.
접근
REST
tokens/{address}/trades, wallets/{address}/trades.WebSocket
dex-trade:{chain}_{tokenAddress}(토큰별) 및 dex-wallet-trade:{chain}_{walletAddress}(지갑별). SDK: client.stream.subscribeTokenTrade / subscribeWalletTrade.Kafka
*.dex.trade 토픽 (Protobuf).GraphQL
유연한 필터. Tokens / Wallets와 JOIN.
다음 단계
Candles (OHLC)
틱 단위가 필요 없을 때 사전 집계 바.
Smart Money
고성과 지갑만 필터링한 거래.