Model data yang digerakkan query
Enam objek di ClickHouse Cloud: markets, price_ticks, trades, satu view FINAL di atasnya, agregat satu menit, dan materialized view-nya — bertipe token ID UInt256, desimal eksak, dan enum.
ClickHouse Seri BUILD
Dalam dua jam Anda mengalirkan data prediction market publik ke service ClickHouse Cloud Anda sendiri, memelihara seri midpoint satu menit saat insert, dan mempublikasikan dashboard denyut pasar — lalu bisa menyatakan apakah sebuah pergerakan datang bersama spread yang melebar atau perdagangan yang makin cepat.
Bukan tutorial trading. Sebuah soal data live.
Prediction market publik adalah salah satu dari sedikit dataset yang benar-benar live, benar-benar berantakan, dan bebas dibaca. Workshop ini hanya memakai API publik Gamma, CLOB, dan Data: tanpa wallet, tanpa deposit, tanpa order, dan tanpa secret Polymarket di titik mana pun.
Bagian menariknya bukan feed-nya, tapi apa yang feed itu lakukan pada desain Anda. WebSocket-nya cepat tapi bukan log yang durable, jadi collector mendeteksi socket yang sepi atau macet, menyambung ulang, dan mem-polling book CLOB publik selama kondisi degraded. Loop terpisah merekonsiliasi trade dengan overlap lima detik dan ID deterministik, jadi trade yang sama datang dua kali tetap tercatat sekali.
Setiap tabel dikunci untuk query yang benar-benar akan Anda jalankan — bucket jam lebih dulu, lalu token atau condition yang Anda kelompokkan — dan seri midpoint satu menit dipelihara saat insert, bukan dihitung ulang setiap dashboard di-refresh.
Yang Anda bawa pulang
Di service ClickHouse Cloud Anda sendiri, disuapi API publik. Satu container Docker stateless adalah satu-satunya hal yang berjalan lokal.
Enam objek di ClickHouse Cloud: markets, price_ticks, trades, satu view FINAL di atasnya, agregat satu menit, dan materialized view-nya — bertipe token ID UInt256, desimal eksak, dan enum.
Heartbeat dan deteksi macet, reconnect, fallback book CLOB REST selama degraded, dan endpoint health tempat degraded adalah status yang jujur, bukan kegagalan.
Loop trade publik dengan overlap lima detik dan ID deterministik, ditambah ReplacingMergeTree sebagai jaring pengaman kedua di belakangnya.
AggregatingMergeTree menyimpan state argMin, argMax, min, max, dan count, difinalisasi dengan fungsi Merge yang sepadan — dan Anda membandingkan baris yang dibaca dengan scan mentahnya.
Probabilitas saat ini, penggerak lima menit, spread dan kesegaran, serta kecepatan volume — sehingga sebuah pergerakan mendapat keyakinan atau keraguan, bukan sekadar headline.
Polymarket market pulse — lima query tersimpan termasuk grafik garis satu menit, dibangun sepenuhnya di konsol ClickHouse Cloud. Tanpa produk dashboard lokal.
Rutenya · 2j30 hands-on
Satu alur, awal sampai selesai: temukan pasarnya, modelkan, alirkan, agregasikan, lalu jelaskan dan publikasikan pergerakannya.
Siapkan macOS atau Ubuntu di WSL 2, pasang clickhousectl dan client ClickHouse, buat service Cloud, dan pastikan preflight mencetak READY.
Minta Gamma memberi pasar aktif tersibuk dan pahami mengapa condition ID dan outcome token ID adalah dua hal berbeda.
Buat tabel market, tick, dan trade bertipe rapi di sekitar filter yang akan mereka layani, plus agregat midpoint satu menit dan materialized view-nya.
Jalankan collector, baca kontrak health-nya, dan buktikan baris benar-benar masuk ke Cloud — dengan mode fixture sebagai fallback teruji untuk feed yang terblokir atau sepi.
Finalisasi state agregat, bandingkan baris yang dibaca dengan padanan mentahnya, dan pastikan menit terbaru terus maju tanpa job refresh terjadwal.
Empat query eksplisit: probabilitas saat ini, outcome mana yang paling bergerak, apakah spread-nya lebar atau quote-nya basi, dan apakah volume trade menanjak.
Simpan lima query dengan nama persisnya dan rangkai Polymarket market pulse dengan empat tampilan terkini plus grafik garis satu menit.
Berikan tabel live ke sebuah ClickHouse Agent dan minta ia mendeteksi pergerakan, menelusurinya lewat spread, kesegaran, dan volume, lalu adili putusannya dengan SQL deterministik dan catat apa yang ia salah nilai.
Ambil query bukti terakhir, hentikan collector, dan petakan jalan menuju ClickPipes untuk relay produksi yang sudah mempublikasikan ke sebuah stream.
Mandiri secara default. Setiap modul menyebut titik awalnya dan diakhiri pemeriksaan selesai yang bisa Anda jalankan sendiri. live, degraded dengan timestamp REST yang segar, dan fixture semuanya status pengajaran yang sah — jalur instructor menyatakan ruangan sedang di status mana, dan tidak pernah menyebut data fixture sebagai live.
Sebelum Anda ikut
Bawa laptop dengan Docker dan satu organisasi ClickHouse Cloud. Pulang dengan feed live, agregat satu menit yang dipelihara saat insert, dan dashboard denyut pasar yang bisa Anda arahkan ke pasar publik mana pun.