03 Transmitir datos en vivo · Instructor

Tiempo

15 minutos. En el minuto 10, cambia al modo fixture a cualquier participante bloqueado o sin datos.

Guion

• WebSocket aporta inmediatez, no durabilidad.
• Las operaciones de Data API se concilian con un solapamiento; los identificadores deterministas hacen seguros los reintentos.
• CLOB REST mantiene BBO/spread actualizados mientras el socket se reconecta.
• degraded es honesto y útil. unhealthy significa que fallan las escrituras en Cloud o todas las fuentes están obsoletas.

Fallos habituales

• Tiempo de espera del handshake WebSocket: espera a last_book_fallback_at; no reinicies en bucle.
• Salud 503: revisa reason, queue_depth y last_clickhouse_write_at.
• Cero ticks después de 60 segundos: usa fixture para que los módulos posteriores sean deterministas.
• Puerto 8090 ocupado: aplica el cambio de puerto indicado en la resolución de problemas.

Reinicio

docker compose --env-file .env.polymarket down
docker compose --env-file .env.polymarket up -d --build collector
curl --fail --silent http://localhost:8090/health | python3 -m json.tool

Al reiniciar se recuperan de ClickHouse Cloud los identificadores recientes y checkpoints de operaciones.