Polymarket Indexer

SELECT
    toStartOfMinute(timestamp) as minute,
    outcome,
    avg(price) as avg_price,
    sum(size) as volume
FROM orderbook_events
WHERE market_id = 'your_market_id'
  AND event_type = 'FILL'
  AND timestamp > now() - INTERVAL 24 HOUR
GROUP BY minute, outcome
ORDER BY minute

SELECT
    timestamp,
    market_id,
    outcome,
    side,
    price,
    size,
    maker,
    taker
FROM orderbook_events
WHERE event_type = 'FILL'
  AND timestamp > now() - INTERVAL 1 HOUR
ORDER BY timestamp DESC
LIMIT 100

SELECT
    e.market_id,
    m.question,
    count(*) as fills,
    sum(e.size * e.price) as volume
FROM orderbook_events e
LEFT JOIN markets m ON e.market_id = m.id
WHERE e.event_type = 'FILL'
  AND e.timestamp > now() - INTERVAL 24 HOUR
GROUP BY e.market_id, m.question
ORDER BY volume DESC
LIMIT 20

SELECT
    taker as wallet,
    count(*) as trades,
    sum(size * price) as volume,
    count(DISTINCT market_id) as markets_traded
FROM orderbook_events
WHERE event_type = 'FILL'
  AND timestamp > now() - INTERVAL 7 DAY
GROUP BY wallet
ORDER BY volume DESC
LIMIT 50

import clickhouse_connect
 
client = clickhouse_connect.get_client(
    host='51.68.240.215',
    port=28123,
    username='your_user',
    password='your_pass',
    database='polymarket'
)
 
df = client.query_df("""
    SELECT * FROM orderbook_events
    WHERE event_type = 'FILL'
      AND timestamp > now() - INTERVAL 1 HOUR
    LIMIT 1000
""")