08 Conclusion

Preuve finale

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;

Vous avez terminé lorsque markets, ticks et midpoint_minutes dépassent zéro et que newest_tick correspond à cette exécution. Un flux direct calme peut légitimement avoir zéro transaction rapprochée ; le mode fixture en produit toujours.

Ce que vous avez construit

• la découverte publique de marchés sans identifiants ;
• un parcours WebSocket en direct avec heartbeat, détection de blocage, reconnexion et repli BBO REST ;
• un parcours de transactions publiques rapprochées avec fenêtres chevauchées et identifiants déterministes ;
• des tables ClickHouse typées conçues autour des filtres réels ;
• un agrégat du point médian à la minute au moment de l'insertion ; et
• un tableau de bord Cloud ou des visualisations SQL enregistrées équivalentes.

Arrêter le collecteur local

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

Cela supprime le conteneur sans état. Les données et requêtes Cloud restent disponibles.

Nettoyage Cloud facultatif

Exécutez ceci uniquement si vous ne voulez plus les données de l'atelier :

DROP DATABASE polymarket;

Supprimez ou mettez en veille le service Cloud via clickhousectl ou la console selon votre politique.

Comment passer à l'échelle en production

L'atelier écrit directement car la source est une API HTTP/WebSocket et le volume est faible. Si un relais de production publie déjà dans Kafka, Kinesis, Pub/Sub ou un stream pris en charge, utilisez ClickPipes pour les offsets gérés, le mappage du schéma, la backpressure et les erreurs. N'ajoutez pas de broker uniquement pour donner à l'atelier un aspect plus distribué.

Revenez au catalogue des ateliers ou comparez ce parcours au parcours AI SRE.