Skip to main content

Historical Tick Store

TraderX's own live ticks and a normalized NYSE TAQ quotes sample, captured into one partitioned Parquet schema queryable through DuckDB.

  • Inherits architectural baseline from: YU06-eod-price-production
  • Generated from: system/architecture.model.json
  • Canonical flows: ../001-baseline-uncontainerized-parity/system/end-to-end-flows.md

Architecture Diagram​

Node Catalog​

NodeKindLabelNotes
price_publisherservicePrice PublisherExisting last-price feed (pricing.*) that tick-store captures from, unchanged.
trade_processorserviceTrade ProcessorExisting trade-fill broadcaster (/accounts/*/trades) that tick-store captures from, unchanged.
natsserviceNATSExisting broker; tick-store adds a subscriber, publishes nothing.
tick_store_captureservicetick-store: capture.pyLong-running subscriber on pricing.* and /accounts/*/trades; batched writes to partitioned Parquet.
taq_sourceactorTAQ CSV (zip)NYSE Daily TAQ Consolidated Quotes CSV, streamed via unzip -p, never extracted to disk.
tick_store_ingestservicetick-store: ingest_taq_quotes.pyOne-shot CLI normalizing a TAQ CQ CSV (via stdin) into the same partitioned schema.
parquet_storeserviceParquet Store (PVC)source=<live
duckdb_queryactorDuckDB Query LayerSymbol/date-range queries and aggregations over the unified store, no server.