PolymarketClickHouse Workshops

03 ライブデータをストリーミングする · インストラクター

ライブで実行し、安全な機能低下を見分け、時間内に会場全体を fixture へ切り替える。

Your computer
macOS terminal: Run workshop commands in Terminal using zsh or bash.

タイミング

15 分。10 分経過時点で、ブロックされている受講者や動きのない受講者を fixture モードに切り替えます。

トークトラック

  • WebSocket が与えるのは即時性であり、耐久性ではありません。
  • Data API の取引はオーバーラップさせて突合します。決定的な ID があるので再実行しても安全です。
  • CLOB REST は、ソケットが再接続している間も BBO とスプレッドを最新に保ちます。
  • degraded は正直で有用な状態です。unhealthy は Cloud への書き込み、またはすべてのソースが古いことを意味します。

よくある失敗

  • WebSocket のハンドシェイクがタイムアウトする: last_book_fallback_at を待ちます。再起動を繰り返さないでください。
  • ヘルスが 503: reason、queue_depth、last_clickhouse_write_at を確認します。
  • 60 秒経っても tick が 0 件: 以降のモジュールを決定的にするため fixture を使います。
  • ポート 8090 が使用中: トラブルシューティングのポート変更を使います。

リセット

docker compose --env-file .env.polymarket down
docker compose --env-file .env.polymarket up -d --build collector
curl --fail --silent http://localhost:8090/health | python3 -m json.tool

再起動すると、直近の ID と取引のチェックポイントが ClickHouse Cloud から復元されます。

このページの内容

JA