08 Encerramento

Prova 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;

Você terminou quando markets, ticks e midpoint_minutes forem maiores que zero e newest_tick corresponder a esta execução. Um feed ao vivo parado pode ter zero negociações reconciliadas; o modo fixture sempre produz negociações.

O que você criou

• descoberta pública de mercados sem credenciais;
• um caminho WebSocket ao vivo com heartbeat, detecção de travamento, reconexão e fallback BBO por REST;
• um caminho de negociações públicas reconciliadas, com janelas sobrepostas e IDs determinísticos;
• tabelas ClickHouse tipadas, projetadas com base nos filtros reais;
• uma agregação do midpoint das cotações por minuto no momento da inserção; e
• um dashboard no Cloud ou visualizações SQL salvas equivalentes.

Interromper o coletor local

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

Isso remove o container sem estado. Os dados e consultas salvas no Cloud permanecem.

Limpeza opcional no Cloud

Execute isto apenas se não quiser mais os dados do workshop:

DROP DATABASE polymarket;

Exclua ou coloque o serviço Cloud em idle pelo clickhousectl ou pelo console, conforme a política da sua organização.

Como isso escala em produção

O workshop grava diretamente porque a origem é uma API HTTP/WebSocket e o volume é pequeno. Se um relay de produção já publicar em Kafka, Kinesis, Pub/Sub ou outro stream compatível, use ClickPipes para offsets gerenciados, mapeamento de esquema, backpressure e tratamento de erros. Não adicione um broker apenas para fazer o workshop parecer mais distribuído.

Volte ao catálogo de workshops ou compare este percurso com a trilha AI SRE.