Stop Building Crypto Data Pipelines.
Start Trading.

pip install algotick   # or copy algotick.py into your project

import asyncio
from algotick import AlgoTickClient

async def main():
    client = AlgoTickClient(api_key="sk_live_...")

    # 1. Check macro safety — is the market stable?
    gex = await client.get_gamma_exposure()
    if gex["aggregate_gex"] < -50:
        print("Market unstable. Halting.")
        return

    # 2. Stream normalized cross-chain events
    async def on_event(data):
        print(f"{data['stream_type']} on {data['chain']}: {data['data']}")

    await client.stream(
        channels=["solana.swaps", "ethereum.flashbots_bids"],
        callback=on_event
    )

asyncio.run(main())

# Get your API key and start querying in seconds

# 1. Market snapshot — 39 real-time metrics
curl https://algotick.dev/v1/snapshot?api_key=YOUR_KEY

# 2. Dealer Gamma Exposure (pre-calculated Black-Scholes)
curl https://algotick.dev/v3/signals/gamma-exposure?api_key=YOUR_KEY

# 3. Orderbook liquidity void detection
curl https://algotick.dev/v4/signals/liquidity-voids?coin=BTC&api_key=YOUR_KEY

# 4. Flashbots MEV congestion score
curl https://algotick.dev/v4/signals/mempool-congestion?api_key=YOUR_KEY

# Query 3 months of Solana DEX swaps directly from R2 (no download)
import duckdb

conn = duckdb.connect()
df = conn.sql("""
    SELECT * FROM read_parquet(
        's3://algotick-data-lake/events/swaps/chain=solana/year=2026/month=*/day=*/data.parquet'
    ) WHERE amount_usd > 10000
    ORDER BY timestamp_ms
""").df()

print(f"{len(df):,} whale swaps found")

import asyncio
from algotick import AlgoTickClient

async def on_market_event(data):
    # Fires the millisecond a Solana swap or Hyperliquid trade happens
    print(f"{data['stream_type']} | {data['chain']} | {data['data']}")

async def main():
    client = AlgoTickClient(api_key="sk_live_12345")

    # 1. Check macro safety via REST
    gex = await client.get_gamma_exposure()
    if gex["aggregate_gex"] < -50:
        print("Market unstable. Halting execution.")
        return

    # 2. Stream normalized cross-chain events via Go WebSocket
    await client.stream(
        channels=["solana.swaps", "hyperliquid.liquidations"],
        callback=on_market_event
    )

asyncio.run(main())