08 Wrap up

최종 증명

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;

markets, ticks, midpoint_minutes가 0보다 크고 newest_tick이 이번 실행과 일치하면 완료된 것입니다. 조용한 실시간 피드에서는 정합화된 거래가 0인 것이 정상일 수 있고, 픽스처 모드는 항상 거래를 만들어냅니다.

무엇을 만들었나

• 자격 증명 없는 공개 시장 탐색;
• 하트비트, 정지 감지, 재연결, REST BBO 폴백을 갖춘 실시간 WebSocket 경로;
• 중첩 구간과 결정적 ID를 갖춘 정합화된 공개 거래 경로;
• 실제 필터를 중심으로 설계된 타입 지정 ClickHouse 테이블;
• 삽입 시점에 계산되는 1분 호가 중간값 집계; 그리고
• Cloud 대시보드 또는 그에 상응하는 저장된 SQL 시각화.

로컬 collector 중지

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

이 명령은 상태 없는 컨테이너를 제거합니다. Cloud 데이터와 저장된 쿼리는 그대로 남습니다.

선택적 Cloud 정리

워크샵 데이터가 더 이상 필요하지 않을 때만 실행하세요:

DROP DATABASE polymarket;

Cloud 서비스는 조직 정책에 따라 clickhousectl 또는 콘솔로 삭제하거나 유휴 상태로 두세요.

프로덕션에서는 어떻게 확장되는가

이 워크샵은 소스가 HTTP/WebSocket API이고 데이터량이 작기 때문에 직접 씁니다. 프로덕션 릴레이가 이미 Kafka, Kinesis, Pub/Sub 또는 다른 지원 스트림에 발행하고 있다면, 오프셋 관리, 스키마 매핑, 백프레셔, 오류 처리를 맡길 수 있는 ClickPipes를 사용하세요. 워크샵이 더 분산된 것처럼 보이게 하려고 브로커를 추가하지는 마세요.

워크샵 카탈로그로 돌아가거나, 이 경로를 AI SRE 트랙과 비교해 보세요.