ClickHouse Chuỗi BUILD
Trong hai giờ, bạn stream dữ liệu thị trường dự đoán công khai vào service ClickHouse Cloud của riêng mình, giữ một chuỗi trung điểm theo từng phút được duy trì ngay khi insert, và công bố một dashboard nhịp đập thị trường — rồi nói được một biến động đi cùng spread rộng hơn hay giao dịch nhanh hơn.
Không phải bài học giao dịch. Một bài toán dữ liệu trực tiếp.
Một thị trường dự đoán công khai là một trong ít tập dữ liệu thật sự trực tiếp, thật sự lộn xộn, và đọc được miễn phí. Workshop này chỉ dùng các API công khai Gamma, CLOB và Data: không ví, không nạp tiền, không đặt lệnh, và không có secret nào của Polymarket ở bất kỳ bước nào.
Phần thú vị không phải bản thân feed, mà là những gì feed đó buộc bạn thay đổi trong thiết kế. WebSocket nhanh nhưng không phải một log bền, nên collector phát hiện socket im lặng hoặc đứng, kết nối lại, và poll book CLOB công khai trong lúc suy giảm. Một vòng lặp riêng đối chiếu giao dịch trên cửa sổ chồng lấn năm giây với ID tất định, nên cùng một giao dịch đến hai lần vẫn chỉ đọng lại một lần.
Mọi bảng đều được đặt key theo đúng những query bạn sẽ thật sự chạy — bucket theo giờ trước, rồi đến token hoặc condition bạn group by — và chuỗi trung điểm theo từng phút được duy trì ngay khi insert thay vì tính lại mỗi lần dashboard làm mới.
Bạn ra về với những gì
Trên service ClickHouse Cloud của riêng bạn, được nuôi bằng các API công khai. Một container Docker không trạng thái là thứ duy nhất chạy trên máy bạn.
Sáu đối tượng trong ClickHouse Cloud: markets, price_ticks, trades, một view FINAL trên chúng, bản tổng hợp theo từng phút, và materialized view của nó — với token ID kiểu UInt256, số thập phân chính xác, và enum.
Heartbeat và phát hiện đứng, kết nối lại, dự phòng đọc book qua CLOB REST trong lúc suy giảm, và một health endpoint nơi degraded là một trạng thái trung thực chứ không phải một thất bại.
Một vòng lặp giao dịch công khai trên cửa sổ chồng lấn năm giây với ID tất định, cộng ReplacingMergeTree làm lưới an toàn thứ hai đứng sau.
AggregatingMergeTree giữ các state argMin, argMax, min, max và count, được finalize bằng các hàm Merge tương ứng — và bạn so số dòng đọc với lần scan dữ liệu thô.
Xác suất hiện tại, những kết quả biến động nhất trong năm phút, spread và độ mới, và tốc độ khối lượng — để một biến động nhận được sự tin cậy hoặc nghi ngờ, thay vì một dòng tiêu đề.
Polymarket market pulse — năm query đã lưu, gồm cả biểu đồ đường theo từng phút, dựng hoàn toàn trong console ClickHouse Cloud. Không cần sản phẩm dashboard nào chạy trên máy.
Lộ trình · 2h30 thực hành
Một mạch liền, từ đầu đến cuối: tìm các thị trường, mô hình hoá, stream, tổng hợp, rồi giải thích và công bố biến động.
Chuẩn bị macOS hoặc Ubuntu trên WSL 2, cài clickhousectl và ClickHouse client, tạo service Cloud, và để bước preflight in ra READY.
Hỏi Gamma những thị trường đang hoạt động nhộn nhịp nhất và hiểu vì sao condition ID và outcome token ID là hai thứ khác nhau.
Tạo các bảng market, tick và trade có kiểu rõ ràng, xoay quanh những filter chúng sẽ phục vụ, cùng bản tổng hợp trung điểm theo từng phút và materialized view của nó.
Khởi động collector, đọc health contract của nó, và chứng minh các dòng đang về Cloud — với chế độ fixture là phương án dự phòng đã kiểm thử cho một feed bị chặn hoặc im lặng.
Finalize các aggregate state, so số dòng đọc với bản tương đương trên dữ liệu thô, và xác nhận phút mới nhất tiến lên mà không cần job làm mới theo lịch.
Bốn query rõ ràng: xác suất hiện tại, kết quả nào động mạnh nhất, spread đang rộng hay báo giá đã cũ, và khối lượng giao dịch có tăng tốc không.
Lưu năm query dưới đúng tên của chúng và lắp nên Polymarket market pulse với bốn view hiện trạng và biểu đồ đường theo từng phút.
Giao các bảng dữ liệu trực tiếp cho một ClickHouse Agent và để nó phát hiện một biến động, điều tra dựa trên spread, độ mới và khối lượng, rồi trọng tài kết luận của nó bằng SQL tất định và ghi lại những gì nó đã sai.
Chốt query chứng minh cuối cùng, dừng collector, và vạch đường sang ClickPipes cho một relay production đã publish sẵn vào một stream.
Mặc định là tự học. Mỗi module nêu điểm khởi đầu và kết thúc bằng một phần kiểm tra hoàn thành bạn tự chạy được. live, degraded với timestamp REST còn mới, và fixture đều là những trạng thái dạy học hợp lệ — lộ trình giảng viên nói rõ cả lớp đang ở trạng thái nào, và không bao giờ gọi dữ liệu fixture là dữ liệu trực tiếp.
Trước khi tham gia
Mang theo một laptop có Docker và một tổ chức ClickHouse Cloud. Ra về với một feed trực tiếp, một bản tổng hợp theo từng phút được duy trì ngay khi insert, và một dashboard nhịp đập thị trường bạn có thể trỏ vào bất kỳ thị trường công khai nào.