Capture native per-order (L3) crypto data (cryptofeed)¶

cryptofeed streams normalised market data over websockets and maintains the order book for you, applying each venue's snapshot and deltas. It is the per-order complement to the CCXT source: where CCXT covers the widest venue list at price-level detail, cryptofeed can also deliver market-by-order (L3) on the venues that publish it — the feed the reconstruction engine was built for.

Install the optional [cryptofeed] extra and use the capture verb:

pip install "ob-analytics[cryptofeed]"

ob-analytics capture cryptofeed --exchange bitstamp --pair BTC-USD --minutes 10 --out /tmp/cap

The level comes from the venue, not from a list¶

A cryptofeed exchange declares the channels it supports. The source reads that declaration: a venue offering a per-order book is captured at L3, and every other venue at L2. Nothing is hardcoded, so the choice tracks cryptofeed's own coverage as it changes.

In cryptofeed 2.4 and 2.5 the venues publishing a per-order book are bitstamp, bitfinex, blockchain, and independent_reserve. Coinbase and Bitso publish price-level data only.

--level forces the choice. Forcing L2 on an L3-capable venue is allowed — it is a coarser view of the same book. Forcing L3 on a venue that does not publish one fails, because the only way to satisfy it would be to invent order IDs that the feed never had.

# A per-order venue, captured at price level instead:
ob-analytics capture cryptofeed --exchange bitstamp --pair BTC-USD --level L2 --out /tmp/cap

# An L2-only venue:
ob-analytics capture cryptofeed --exchange binance --pair BTC-USDT --out /tmp/cap

Each run produces a self-contained directory:

How the per-order events are derived¶

cryptofeed's L3 venues do not agree on what a book callback carries, so the source handles both shapes:

• A populated delta — (order_id, price, quantity) triples, with a quantity of 0 meaning the order is gone — is mapped entry by entry. This is the venue's own account of what changed, so a venue that models a price move as a removal followed by an add (bitfinex) keeps that meaning: a move loses queue position, and recording it as one order quietly changing price would misstate the queue.
• No delta, or an empty one — bitstamp resends the whole book on every message, and bitfinex, blockchain and independent_reserve all open that way. The maintained book is diffed against the tracked orders to recover the same created / changed / deleted vocabulary.

Order IDs are the venue's own throughout, exactly as published — integers on bitstamp, bitfinex and blockchain, UUID strings on independent_reserve. The shared schema keys orders by identity rather than by integer, so nothing is re-labelled on the way through.

At shutdown every order still resting is closed out with a synthetic deleted, so each ID in orders.csv has a complete lifecycle.

Dropped messages and reconnects¶

cryptofeed owns reconnection — it re-establishes a dropped connection itself, so a capture cannot count reconnects directly. What it can see is the discontinuity a reconnect or a dropped message leaves in the venue's own sequence numbers. Those are recorded per row in both orders.csv and depth.csv, and each run reports sequence_gaps (how many breaks) and sequence_missing (how many numbers went by unseen) in meta.json.

For the authoritative check, replay the capture and score it:

from ob_analytics.analytics import detect_sequence_gaps
from ob_analytics.bitstamp import BitstampLoader
from ob_analytics.config import PipelineConfig

events = BitstampLoader(config=PipelineConfig(track_sequence=True)).load("orders.csv")
print(detect_sequence_gaps(events))

A venue that publishes no sequence number is never scored, and reports zero.

Flags¶

Which source for which venue¶

Prefer one source per venue rather than two ways to capture the same thing:

• cryptofeed when you want L3, or when its websocket handling for a venue is the more robust path;
• CCXT for breadth and for the prediction markets (Kalshi, Polymarket), which cryptofeed does not cover.

See also¶

• Capture CCXT venues — the price-level source covering the widest venue list
• Capture live data — the capture framework and writing a bespoke venue
• Process L2 (price-level) feeds — what a captured depth.csv flows through
• Check data quality — run audit on the captured output