ClickHouse Serie BUILD
En dos horas y media transmites datos públicos de mercados de predicción a tu propio servicio ClickHouse Cloud, mantienes una serie de precios medios de un minuto actualizada al insertar y publicas un dashboard de pulso del mercado; después determinas si el movimiento vino acompañado de un spread más amplio o una negociación más rápida.
No es un tutorial de trading. Es un problema de datos en vivo.
Un mercado público de predicciones es uno de los pocos conjuntos de datos realmente en vivo, realmente imperfectos y gratuitos para leer. Este taller solo usa las API públicas Gamma, CLOB y Data: sin cartera, depósito, orden ni secreto de Polymarket en ningún momento.
Lo interesante no es el feed, sino lo que le hace a tu diseño. WebSocket es rápido, pero no es un log duradero, así que el colector detecta un socket silencioso o bloqueado, vuelve a conectarse y consulta el libro CLOB público mientras está degradado. Otro bucle reconcilia operaciones con un solapamiento de cinco segundos e identificadores deterministas, de modo que una operación recibida dos veces se almacena una sola vez.
Cada tabla se organiza para las consultas que realmente ejecutarás: primero un intervalo de una hora y después el token o la condición por los que agrupas; la serie de precios medios de un minuto se mantiene al insertar en lugar de recalcularse con cada actualización del dashboard.
Lo que te llevas
En tu propio servicio ClickHouse Cloud, alimentado por API públicas. Un contenedor Docker sin estado es lo único que se ejecuta localmente.
Seis objetos en ClickHouse Cloud: markets, price_ticks, trades, una vista FINAL sobre ellos, la agregación de un minuto y su materialized view; tipados con identificadores de token UInt256, decimales exactos y enums.
Heartbeat y detección de bloqueo, reconexión, alternativa del libro mediante CLOB REST durante la degradación y un endpoint de salud donde degraded es un estado honesto, no un fallo.
Un bucle de operaciones públicas con solapamiento de cinco segundos e identificadores deterministas, más ReplacingMergeTree como segunda red de seguridad.
Un AggregatingMergeTree que guarda estados de argMin, argMax, min, max y count, finalizados con las funciones Merge correspondientes; además, comparas las filas leídas con el escaneo en bruto.
Probabilidad actual, mayores movimientos en cinco minutos, spread y frescura y velocidad del volumen, para que un movimiento reciba confianza o duda en vez de un titular.
Pulso del mercado Polymarket — cinco consultas guardadas, incluido el gráfico de línea de un minuto, creado por completo en la consola de ClickHouse Cloud. Sin producto local de dashboards.
El recorrido · 2h30 prácticas
Un solo flujo, de principio a fin: encuentra los mercados, modélalos, transmítelos, agrégalos y después explica y publica el movimiento.
Prepara macOS o Ubuntu en WSL 2, instala clickhousectl y el cliente de ClickHouse, crea el servicio Cloud y consigue que la comprobación previa muestre READY.
Pide a Gamma los mercados activos con mayor actividad y aprende por qué un identificador de condición y uno de token de resultado son cosas distintas.
Crea las tablas tipadas de mercados, ticks y operaciones en torno a los filtros que atenderán, además de la agregación de precio medio de un minuto y su materialized view.
Inicia el colector, lee su contrato de salud y demuestra que llegan filas a Cloud, con el modo fixture como alternativa probada para un feed bloqueado o silencioso.
Finaliza los estados agregados, compara las filas leídas con el equivalente en bruto y confirma que avanza el minuto más reciente sin una tarea programada de actualización.
Cuatro consultas explícitas: probabilidad actual, qué resultado se movió más, si el spread es amplio o la cotización está obsoleta y si el volumen de operaciones se aceleró.
Guarda las cinco consultas con sus nombres exactos y monta Pulso del mercado Polymarket con cuatro vistas actuales y el gráfico de línea de un minuto.
Entrega las tablas en vivo a un ClickHouse Agent y haz que detecte un movimiento, lo investigue según spread, frescura y volumen; después arbitra su veredicto con SQL determinista y registra sus errores.
Captura la consulta final de prueba, detén el colector y traza el camino a ClickPipes para un relay de producción que ya publique en un stream.
Autoguiado de forma predeterminada. Cada módulo indica su punto inicial y termina con una comprobación que puedes ejecutar. live, degraded con marcas de tiempo REST recientes y fixture son estados didácticos válidos: el itinerario del instructor indica cuál usa la sala y nunca llama datos en vivo a los datos fixture.
Antes de participar
Trae un portátil con Docker y una organización de ClickHouse Cloud. Sal con un feed en vivo, una agregación de un minuto mantenida al insertar y un dashboard de pulso del mercado que puedes apuntar a cualquier mercado público.