08 Cierre

Prueba final

SELECT
    (SELECT uniqExact(condition_id) FROM polymarket.markets FINAL) AS markets,
    (SELECT count() FROM polymarket.price_ticks) AS ticks,
    (SELECT count() FROM polymarket.trades_clean) AS trades,
    (SELECT count() FROM polymarket.market_midpoints_1m) AS midpoint_minutes,
    (SELECT max(event_at) FROM polymarket.price_ticks) AS newest_tick;

Has terminado cuando markets, ticks y midpoint_minutes superen cero y newest_tick corresponda a esta ejecución. Un feed en vivo tranquilo puede tener cero operaciones conciliadas; el modo fixture siempre produce operaciones.

Qué has creado

• descubrimiento público de mercados sin credenciales;
• una ruta WebSocket en vivo con heartbeat, detección de bloqueo, reconexión y alternativa BBO por REST;
• una ruta de operaciones públicas conciliadas con ventanas solapadas e identificadores deterministas;
• tablas ClickHouse tipadas y diseñadas según filtros reales;
• un agregado del punto medio de cotización por minuto al insertar; y
• un panel de Cloud o visualizaciones SQL guardadas equivalentes.

Detener el colector local

docker compose --env-file .env.polymarket down

Esto elimina el contenedor sin estado. Los datos y consultas guardadas de Cloud permanecen.

Limpieza opcional en Cloud

Ejecuta esto solo si ya no quieres los datos del taller:

DROP DATABASE polymarket;

Elimina o pon en idle el servicio Cloud con clickhousectl o la consola según la política de tu organización.

Cómo escala en producción

El taller escribe directamente porque el origen es una API HTTP/WebSocket y el volumen es pequeño. Si un relay de producción ya publica en Kafka, Kinesis, Pub/Sub u otro stream compatible, usa ClickPipes para offsets gestionados, mapeo de esquema, backpressure y gestión de errores. No añadas un broker solo para que el taller parezca más distribuido.

Vuelve al catálogo de talleres o compara este camino con el itinerario AI SRE.