08 Tổng kết

Bằng chứng cuối cùng

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;

Bạn hoàn tất khi markets, ticks và midpoint_minutes lớn hơn không và newest_tick khớp với lần chạy này. Một feed trực tiếp ít giao dịch có thể hoàn toàn hợp lệ khi không có giao dịch nào được đối chiếu; chế độ fixture thì luôn tạo ra giao dịch.

Bạn đã xây dựng gì

• khám phá thị trường công khai mà không cần thông tin đăng nhập nào;
• một đường dẫn WebSocket trực tiếp có heartbeat, phát hiện treo, kết nối lại và dự phòng BBO qua REST;
• một đường dẫn giao dịch công khai đã được đối chiếu với các cửa sổ chồng lấp và ID tất định;
• các bảng ClickHouse có kiểu rõ ràng, được thiết kế quanh các bộ lọc thực tế;
• một aggregate quote-midpoint theo phút được tính ngay lúc insert; và
• một dashboard trên Cloud hoặc các trực quan hóa SQL đã lưu tương đương.

Dừng collector cục bộ

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

Lệnh này xóa container không lưu trạng thái. Dữ liệu trên Cloud và các truy vấn đã lưu vẫn còn.

Dọn dẹp Cloud (không bắt buộc)

Chỉ chạy phần này nếu bạn không còn muốn giữ dữ liệu của workshop:

DROP DATABASE polymarket;

Xóa hoặc đưa service trên Cloud về trạng thái nghỉ thông qua clickhousectl hoặc console theo chính sách của tổ chức bạn.

Cách mở rộng trong production

Workshop ghi trực tiếp vì nguồn là một API HTTP/WebSocket và khối lượng nhỏ. Nếu một relay production đã publish sang Kafka, Kinesis, Pub/Sub hoặc một luồng khác được hỗ trợ, hãy dùng ClickPipes để có offset, mapping schema, backpressure và xử lý lỗi được quản lý sẵn. Đừng thêm một broker chỉ để workshop trông có vẻ phân tán hơn.

Trở lại danh mục workshop hoặc so sánh lộ trình này với lộ trình AI SRE.