โมเดลข้อมูลที่ขับด้วยคิวรี
หกอ็อบเจกต์ใน ClickHouse Cloud: markets, price_ticks, trades, วิว FINAL บนตารางเหล่านั้น ค่า aggregate ราย 1 นาที และ materialized view ของมัน — กำหนดชนิดด้วย token ID แบบ UInt256 ทศนิยมแบบเที่ยงตรง และ enum
ClickHouse BUILD Series
ในสองชั่วโมง คุณสตรีมข้อมูลตลาดทำนายผลสาธารณะเข้าเซอร์วิส ClickHouse Cloud ของคุณเอง ดูแลชุดข้อมูล midpoint ราย 1 นาทีให้อัปเดตตอน insert และเผยแพร่แดชบอร์ดจับชีพจรตลาด — แล้วบอกได้ว่าความเคลื่อนไหวนั้นมาพร้อม spread ที่กว้างขึ้นหรือการเทรดที่เร็วขึ้น
ไม่ใช่บทเรียนการเทรด แต่เป็นโจทย์ข้อมูลสด
ตลาดทำนายผลสาธารณะเป็นหนึ่งในไม่กี่ชุดข้อมูลที่สดจริง รกจริง และอ่านได้ฟรี เวิร์กช็อปนี้ใช้เฉพาะ API สาธารณะ Gamma, CLOB และ Data: ไม่มีวอลเล็ต ไม่มีการฝากเงิน ไม่มีคำสั่งซื้อขาย และไม่มี secret ของ Polymarket ในทุกขั้นตอน
ส่วนที่น่าสนใจไม่ใช่ตัวฟีด แต่คือสิ่งที่ฟีดทำกับการออกแบบของคุณ WebSocket เร็วแต่ไม่ใช่ log ที่ทนทาน ตัว collector จึงตรวจจับซ็อกเก็ตที่เงียบหรือค้าง reconnect แล้วดึงข้อมูล book จาก CLOB สาธารณะระหว่างที่อยู่ในสภาพ degraded อีกลูปหนึ่งจะ reconcile เทรดบนช่วงเวลาเหลื่อมกันห้าวินาทีด้วย ID แบบกำหนดค่าได้แน่นอน เทรดเดียวกันที่มาถึงสองครั้งจึงลงเพียงครั้งเดียว
ทุกตารางถูกกำหนดคีย์ตามคิวรีที่คุณจะรันจริง — บักเก็ตรายชั่วโมงมาก่อน แล้วจึงเป็นโทเคนหรือ condition ที่คุณ group by — และชุดข้อมูล midpoint ราย 1 นาทีถูกดูแลตอน insert แทนที่จะคำนวณใหม่ทุกครั้งที่แดชบอร์ดรีเฟรช
สิ่งที่คุณจะได้กลับไป
บนเซอร์วิส ClickHouse Cloud ของคุณเอง ป้อนด้วย API สาธารณะ สิ่งเดียวที่รันในเครื่องคือ Docker container ไร้สถานะหนึ่งตัว
หกอ็อบเจกต์ใน ClickHouse Cloud: markets, price_ticks, trades, วิว FINAL บนตารางเหล่านั้น ค่า aggregate ราย 1 นาที และ materialized view ของมัน — กำหนดชนิดด้วย token ID แบบ UInt256 ทศนิยมแบบเที่ยงตรง และ enum
heartbeat และการตรวจจับการค้าง การ reconnect การถอยไปอ่าน book ผ่าน CLOB REST ระหว่างที่ degraded และ health endpoint ที่ degraded เป็นสถานะที่ซื่อตรง ไม่ใช่ความล้มเหลว
ลูปอ่านเทรดสาธารณะบน ช่วงเวลาเหลื่อมกันห้าวินาที ด้วย ID แบบกำหนดค่าได้แน่นอน บวก ReplacingMergeTree เป็นตะแกรงกันพลาดชั้นที่สองอยู่ข้างหลัง
AggregatingMergeTree ที่ถือสถานะ argMin, argMax, min, max และ count แล้ว finalize ด้วยฟังก์ชัน Merge ที่คู่กัน — และคุณเทียบจำนวนแถวที่อ่านกับการสแกนดิบ
ความน่าจะเป็นปัจจุบัน ตัวที่ขยับมากสุดในห้านาที spread และความสด และความเร็วของวอลุ่ม — ความเคลื่อนไหวจึงได้ทั้งความมั่นใจหรือข้อกังขา แทนที่จะได้แค่พาดหัว
Polymarket market pulse — ห้าคิวรีที่บันทึกไว้ รวมถึงกราฟเส้นราย 1 นาที สร้างทั้งหมดในคอนโซล ClickHouse Cloud ไม่มีผลิตภัณฑ์แดชบอร์ดในเครื่อง
เส้นทาง · ลงมือทำ 2h30
หนึ่งสายงาน ตั้งแต่ต้นจนจบ: หาตลาด สร้างโมเดล สตรีมเข้ามา รวมค่า แล้วอธิบายและเผยแพร่ความเคลื่อนไหว
เตรียม macOS หรือ Ubuntu บน WSL 2 ติดตั้ง clickhousectl กับ ClickHouse client สร้างเซอร์วิสบน Cloud แล้วทำให้ preflight พิมพ์ READY
ถาม Gamma หาตลาดที่คึกคักที่สุดซึ่งยังเปิดอยู่ และเรียนรู้ว่าทำไม condition ID กับ outcome token ID เป็นของต่างกัน
สร้างตาราง market, tick และ trade ที่กำหนดชนิดชัดเจน โดยออกแบบรอบตัวกรองที่มันจะรองรับ พร้อมค่า aggregate midpoint ราย 1 นาทีและ materialized view ของมัน
เริ่ม collector อ่านสัญญา health ของมัน และพิสูจน์ว่าแถวลงถึง Cloud จริง — โดยมีโหมด fixture เป็นทางถอยที่ทดสอบแล้วสำหรับฟีดที่ถูกบล็อกหรือเงียบ
finalize สถานะของ aggregate เทียบจำนวนแถวที่อ่านกับของเทียบเท่าแบบดิบ และยืนยันว่านาทีล่าสุดเดินหน้าโดยไม่มีงานรีเฟรชตามตาราง
สี่คิวรีที่ชัดเจน: ความน่าจะเป็นปัจจุบัน ผลลัพธ์ไหนขยับมากที่สุด spread กว้างอยู่หรือ quote เก่าไปแล้ว และวอลุ่มเทรดเร่งขึ้นหรือไม่
บันทึกห้าคิวรีด้วยชื่อที่กำหนดไว้ตรงตัว แล้วประกอบ Polymarket market pulse จากสี่วิวสถานะปัจจุบันกับกราฟเส้นราย 1 นาที
ยกตารางสดให้ ClickHouse Agent แล้วให้มันตรวจจับความเคลื่อนไหว สืบหาสาเหตุเทียบกับ spread ความสด และวอลุ่ม จากนั้นตัดสินคำวินิจฉัยของมันด้วย SQL ที่ให้ผลแน่นอน และบันทึกว่ามันพลาดอะไร
เก็บคิวรีพิสูจน์ผลชุดสุดท้าย หยุด collector และวางเส้นทางไปสู่ ClickPipes สำหรับ relay ระดับโปรดักชันที่ส่งข้อมูลออกเป็นสตรีมอยู่แล้ว
ค่าเริ่มต้นคือทำเองตามจังหวะของคุณ ทุกโมดูลระบุจุดเริ่มต้นและจบด้วยการตรวจสอบความสำเร็จที่คุณรันเองได้ ทั้ง live, degraded ที่มี timestamp จาก REST ใหม่สด และ fixture ล้วนเป็นสถานะที่ใช้สอนได้ — แทร็กผู้สอนจะบอกว่าห้องอยู่ในสถานะไหน และไม่เรียกข้อมูล fixture ว่าข้อมูลสด
ก่อนเข้าร่วม
เตรียมแล็ปท็อปที่มี Docker และองค์กรบน ClickHouse Cloud มา แล้วกลับไปพร้อมฟีดข้อมูลสด ค่า aggregate ราย 1 นาทีที่ดูแลตอน insert และแดชบอร์ดจับชีพจรตลาดที่คุณชี้ไปที่ตลาดสาธารณะไหนก็ได้