dextrades 0.1.4

High-performance DEX swap streaming and analysis (Rust/PyO3)

DexTrades 🦄

A Python library for streaming DEX trades from RPC nodes.

✨ Features

• Direct On-Chain Data: Pulls event logs directly from a given RPC URL, requiring no indexers or third-party APIs. It currently decodes swaps from Uniswap V2 and V3.

• Data Enrichment Pipeline: The library can enrich raw log data with:

  • Token metadata (symbols, decimals) for readable amounts.
  • Block timestamps for each swap.
  • USD values calculated using Chainlink ETH/USD price feeds at the swap's block height.

• Rust Core: Built with a Rust backend (PyO3, alloy) for processing. It implements RPC provider racing, a circuit breaker, and automatic retries for connection resilience.

• Friendly Python API: Provides an async generator to stream trades. Enrichments are controlled via boolean flags. Supports streaming individual swaps or Apache Arrow batches.

📦 Installation

Quick Install

Using uv (recommended):

uv add dextrades

Or with pip:

pip install dextrades

Platform Support

Pre-built wheels available for:

• 🍎 macOS: Intel (x86_64) + Apple Silicon (arm64)
• 🪟 Windows: x64 + x86 (32-bit)
• 🐍 Python: 3.12 and 3.13

Linux Installation: Due to cryptographic library compilation requirements, Linux users should install from source:

# Install Rust first (if not already installed)
curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh

# Install from source
pip install dextrades --no-binary=dextrades

Alternatively, use the development Docker setup for a containerized environment.

💻 Usage

The Client manages connections to one or more RPC endpoints. The stream_swaps method returns an async iterator of swap events.

import asyncio
import dextrades

urls = [
    "https://eth-pokt.nodies.app",
    "https://ethereum.publicnode.com",
]
with dextrades.Client(urls) as client:
    # Stream a small block range; normalized token amounts included
    async for swap in client.stream_swaps(
        ["uniswap_v2", "uniswap_v3"],
        17000003, 17000003,
        batch_size=1,
        enrich_timestamps=True,
        enrich_usd=True,
    ):
        print(
            swap.get("dex_protocol"),
            swap.get("token_sold_symbol"), swap.get("token_sold_amount"),
            "→",
            swap.get("token_bought_symbol"), swap.get("token_bought_amount"),
            "USD:", swap.get("value_usd"),
        )

Example Output

time                 dex           bought           sold              value_usd  trader  hash  
-----------------------------------------------------------------------------------------------------------------------------
2023-04-08 01:58:47  Uniswap V2    0.0529  WETH     98.9990  USDC        $99.00  0x5eA7  0x37f7
2023-04-08 01:58:47  Uniswap V2    0.0398  XMON      0.0529  WETH        $98.63  0x5eA7  0x37f7
2023-04-08 01:58:47  Uniswap V2    0.0452  WETH      0.7000  QNT         $84.38  0x4a30  0x5428
2023-04-08 01:58:47  Uniswap V2    3.2402  WETH      2.9994  PAXG     $6,045.62  0xdBC2  0x8f46

🗺️ Roadmap

• Uniswap V2
• Uniswap V3
• and deduplication
• Enrichments:
  • token metadata
  • trade direction
  • timestamps
  • USD values via Chainlink
  • USD values via stablecoin passthrough
• RPC provider
  • racing
  • retries
  • circuit breakers
  • sharded getLogs
• Python API
• CLI
• example and demo
• benchmarks
• additional enrichments:
  • trader balance
  • Uniswap V3 Quoter fallback for non-WETH/stable tokens
• Chainlink Feed Registry (USD feeds) and multi-chain aggregator addresses
• CLI UX polish (enrichment flags, simple table mode)
• Light metrics: stage counters and provider health snapshot
• Additional DEX protocols
• Optional persistent caches and Parquet/Polars export helpers