When to Use
Invoke this skill for a high-rate trade-tick stream when a downstream strategy or analytics consumer has a measured processing ceiling and cannot safely keep every input tick. The engine monitors per-symbol arrival rate, emits every 1:N ticks during overload, and aggregates skipped trade volume and price-volume notional into the emitted sample.
The default target of 5,000 ticks/second is an example capacity parameter, not a universal market-data standard. Calibrate it from measured CPU, queue, latency, and downstream correctness budgets.
When NOT to Use
- Do not use sampled output for order-book reconstruction, quote protection, spread/microstructure signals, queue-position models, latency-sensitive execution, or regulatory/compliance records that require the complete feed.
- Do not use it to repair feed gaps, sequence gaps, duplicate messages, or venue recovery state. Detect and reconcile those upstream before sampling.
- Do not drop residual aggregates at shutdown, symbol removal, or feed restart; call
flush,flush_all, orreset_symbol(flush=True)and persist the result. - Do not treat aggregate VWAP as an OHLC bar or assume it preserves the path, timing, or extrema of skipped trades.
Prerequisites
- A trade-tick feed with documented symbol identity, sequence semantics, event timestamps, price units, and volume units.
- A measured per-symbol processing target and an explicit policy for overload, feed restart, sequence reset, and symbol lifecycle.
- Downstream consumers that understand
SampledTick.aggregated_tick_count,sampling_factor, and syntheticis_flushrecords. - A durable handoff or audit path for emitted samples, validation errors, and flush/recovery events.
- Python 3.10+.
Workflow
- Set the capacity contract: Construct
AdaptiveTickSamplerEngine(target_max_rate_per_sec=...)with a positive integer target. Keepenforce_monotonic_sequence=Trueunless the feed contract explicitly permits another policy. - Validate feed identity upstream: Verify symbol, sequence, timestamp, price, and volume semantics. The engine rejects empty symbols, non-finite values, non-positive prices/volumes, duplicate or decreasing sequences, and backwards event timestamps.
- Ingest one trade tick at a time: Call
ingest_tick(...). Under the target rate it emits a passthrough aggregate; above the target it computesk = ceil(rate / target)with a minimum sampled factor of 2. - Consume explicit metadata: Use
modeandsampling_factorto identify policy,aggregated_tick_countto identify how many raw trades are represented, andis_flushto distinguish synthetic residual output. Treataggregated_tick_count > 1— notmode— as the test for whetherpriceis a VWAP rather than a traded price, because aPASSTHROUGHemission also drains any residual sampled block. - Handle errors fail-closed: Route validation exceptions to the feed-integrity path. Do not retry the same malformed or duplicate tick as if it were new data.
- Manage lifecycle: Call
flush(symbol)for an individual stream,flush_all()during shutdown/checkpointing, andreset_symbol(flush=True)when a symbol leaves the stream or its sequence domain resets. - Monitor quality: Track input/output rates, sampling factor, aggregate counts, volume/notional reconciliation, validation failures, flush counts, queue latency, and downstream processing latency.
Common Pitfalls
- Discarding skipped volume: Emitting only the selected tick loses traded volume and corrupts aggregate VWAP.
- Calling the result a full feed: A VWAP aggregate preserves volume and notional, not every price path, quote, or order-book event.
- Keying on
modeto detect a raw trade: when the rate falls back below target mid-block, the draining emission reportsPASSTHROUGHwithsampling_factor=1while still carryingaggregated_tick_count > 1and a VWAP price no venue printed. Onlyaggregated_tick_countseparates a raw trade from an aggregate. - Accepting duplicate or out-of-order data: Repeated trades double-count volume; backwards event time corrupts rolling-rate windows.
- Using wall-clock flush timestamps: A flush must remain deterministic in replay; the implementation defaults to the last event timestamp unless an explicit later timestamp is supplied.
- Leaking symbol state: Long-lived feeds must reset inactive symbols after flushing so per-symbol dictionaries do not grow without bound.
- Sampling before feed recovery: Sequence gaps and venue recovery require upstream reconciliation; sampling cannot infer missing trades.
Verification
Run the focused test suite:
python -m unittest discover -s skills/adaptive-sampling-under-extreme-tick-rates/scriptsThe tests cover passthrough, the rate == target boundary, overload sampling, volume/notional preservation across a burst, the PASSTHROUGH drain of a partial sampled block, zero timestamps, deterministic flushes, rejection of a flush timestamp preceding the last accepted tick, sorted flush_all, reset_symbol with and without a flush, duplicate/out-of-order rejection, the optional non-monotonic sequence policy, malformed tick values, invalid targets, symbol isolation, state-neutral rejection of an overflowing aggregate, and concurrent multi-threaded ingestion of a shared symbol. Production sign-off additionally requires replaying calibrated bursts and verifying downstream reconciliation against raw input totals.