P1 Ingest
Schema / DB
Ledger
Replay
Dev
Frames Ingested
0
raw_stream_frames
Sources
0
DISTINCT source
Last Event
—
MAX(event_ts)
Replay Hash
—
sha256[:8]
Row Counts per Tabella
SELECT COUNT(*)
| Table | Phase | Rows | Stato |
|---|
Ingest Log
—nessun frame — avvia un run per popolare
Schema Info
| schema_version | v1 |
| DB prod target | PostgreSQL 16.x |
| DB dev/local | DuckDB 1.x ADR-0003 |
| DDL sorgente | .doc/20_canonici/05_SCHEMA/*.sql |
| Traduzioni DuckDB | JSONB→JSON · BIGSERIAL→sequence |
| Invarianti record | schema_version · source · ingest_ts · event_ts · run_id |
Migrations Applied
| Filename | Dialect | SHA256 | Stato |
|---|
Tabelle (schema v1)
| Table | Primary Key | Phase |
|---|---|---|
| raw_stream_frames | (run_id, source, seq) | P1 |
| canonical_orderbook | (run_id, market_id, selection_id, side, level, asof_ts) | P2 |
| canonical_events | (event_id) | P2 |
| model_outputs | (run_id, market_id, selection_id, model_name, asof_ts) | P3 |
| value_signals | (run_id, market_id, selection_id, side, asof_ts) | P4 |
| decisions | (decision_id) | P5 |
| orders | (client_order_id) | P6 |
| ledger_events | (ledger_seq) — append-only | P6 |
| clv_marks | (run_id, client_order_id, mark_ts) | P6 |
Ledger Events
0
append-only
Orders
0
client_order_id
Decisions
0
P5 output
ledger_events — ultimi record
append-only · mai UPDATE/DELETE
| ledger_seq | event_id | event_type | client_order_id | amount | event_ts |
|---|---|---|---|---|---|
| P6 Execute non implementato — tabella vuota | |||||
RawStreamStore.replay()
replay(run_id, source=None) → frames in ordine deterministico ORDER BY source, seq.replay_hash(run_id) → sha256 del dataset per verifica integrità.Frames caricati da
GET /api/ingest/frames — filtro per run_id non ancora implementato.
Run ID
Source (opt.)
Frames — run corrente
| seq | source | stream_type | event_ts | schema_ver |
|---|
pytest
168/168
0 failed
GUARDIAN lint
PASS
critical profile
docs-check
PASS
hard mode
ruff
CLEAN
E F I · len 100
Test Files
| File | Tests | Esito |
|---|
CI Pipeline
| 1. guardian lint --profile critical | PASS |
| 2. guardian docs-check --mode hard | PASS |
| 3. pytest | 168 passed |
Commit Recenti