Gemini WebSocketフィードの概要

Gemini APIは、 WebSocketフィードを通じてリアルタイム市場データを提供し、開発者とトレーダーが注文帳の変更、取引、ティッカー情報の瞬間的な更新を受け取ることができます。これらのフィードは、アルゴリズム取引システム、市場監視ツール、価格警告サービスなど、低遅延データを必要とするアプリケーションに不可欠です。ポーリングを必要とするREST APIとは異なり、WebSocket接続は持続的な双方向通信チャネルを維持し、頭上を削減し、データのタイムリーな配信を確保します。

Geminiの主要なWebSocketエンドポイントはwss://api.gemini.com/v1/marketdataです。このエンドポイントはパブリック市場データをストリーミングし、基本アクセスのための認証は必要ありません。すべてのメッセージはJSON形式で配信されるため、さまざまなプログラミング環境に解析して統合しやすくなります。

利用可能なWebSocketチャネル

Geminiは、特定の種類の市場データを提供するように設計されたいくつかのWebSocketチャネルをサポートしています。利用可能なチャネルには次のものが含まれます。

• 市場データフィード：入札、尋ね、貿易の実行を含む注文帳のリアルタイムの更新をストリーミングします。
• ハートビートメッセージ：接続がアクティブであり、データが送信されていることを示す定期的な信号。
• ティッカーの更新：最終価格、ボリューム、および入札/尋ねるspreadを含む概要レベルの価格情報。
• 取引実行通知：取引所での完了した取引のリアルタイムレポート。

各チャネルは、WebSocket接続を確立するときに目的のシンボルを指定することによりアクセスできます。たとえば、 BTCUSDまたはETHUSDに接続すると、その取引ペアに固有のデータがストリーミングされます。

Gemini WebSocketに接続します

Gemini Websocketフィードへの接続を確立するには、次の手順に従ってください。

• Pythonのwebsocket-clientやnode.jsのwsなどのサポートされているライブラリを使用してWebSocketクライアントを開きます。
• エンドポイントに接続： wss://api.gemini.com/v1/marketdata 。
• クエリ文字列のsymbolsパラメーターを使用して、トレーディングペアを指定します。例： wss://api.gemini.com/v1/marketdata/BTCUSD 。
• 着信メッセージを聞いて、それに応じてJSONペイロードを処理します。

Pythonを使用した例は次のとおりです。

 import websocket import json def on_message（ws、message）：




data = json.loads(message) print(data) def on_error（ws、error）： data = json.loads(message) print(data)
 
def on_close（ws、close_status_code、close_msg）： print(f'Error: {error}')
 
def on_open（ws）： print('Connection closed')
 
接続を確立しますprint('Connected to Gemini WebSocket')
 ws = websocket.websocketapp（ 'wss：//api.gemini.com/v1/marketdata/btcusd'、
 
 on_open=on_open, on_message=on_message, on_error=on_error, on_close=on_close) ws.run_forever（） on_open=on_open, on_message=on_message, on_error=on_error, on_close=on_close)

このスクリプトは、 BTCUSD市場データフィードに接続し、すべての受信メッセージを印刷します。受信したデータには、イベントタイプ、シンボル、入札、 ASKS 、および取引が含まれます。

WebSocketメッセージ構造の理解

Gemini WebSocketから受信した各メッセージには、標準化されたJSON構造が含まれています。重要なフィールドには以下が含まれます。

• タイプ： update 、 heartbeat 、 initialなどのメッセージカテゴリを示します。
• EventID ：イベントのユニークな識別子。
• タイムスタンプ：イベントが発生したときのミリ秒単位のUnixタイムスタンプ。
• シンボル：トレーディングペア（例： BTCUSD ）。
• 入札と尋ねる：価格レベルの配列と対応する数量。
• 変更：注文書の更新のリスト、価格、金額、および側面（ buyまたはsell ）を示します。

更新メッセージの例：

 { 'type': 'update', 'eventId': 123456789, 'timestamp': 1717000000000, 'symbol': 'BTCUSD', 'changes': [ ['buy', '65000.00', '0.5'], ['sell', '65001.50', '0.3']

] }

この例では、変更配列は0.5 BTCの65000.00での新しい入札と、0.3 BTCで65001.50で新しい質問を示しています。クライアントは、注文書のローカルコピーを維持し、これらの変更を段階的に適用して、現在の市場状態を反映する必要があります。

注文帳の同期の取り扱い

WebSocketの更新の段階的性質により、注文帳を正しく初期化することが重要です。 Geminiは、接続時に初期スナップショットを送信し、その後に更新メッセージが続きます。正確性を確保するには：

• 最初の入札を保存し、最初のメッセージを受信したときに尋ねます。
• その後の各changesエントリをローカルオーダーブックに適用します。
• 入札を下降順序で並べ替え、価格で昇順で要求します。
• 数量がゼロに達したら価格レベルを削除します。

たとえば、 ['buy', '65000.00', '0.0']などの変更を処理する場合、 65000.00の入札は注文帳から削除する必要があります。このロジックを維持することにより、アプリケーションが市場の真の状態を反映することが保証されます。

レート制限と接続管理

Geminiは、連続ストリーミング用に設計されているため、WebSocket接続に厳密な速度制限を課しません。ただし、非アクティブまたは過度のメッセージバックログのために接続が終了する場合があります。信頼性を維持するため：

• 指数バックオフを使用して再接続ロジックを実装します。
• Connection closedイベントを監視し、セッションを再起動します。
• ハートビートメカニズムを使用して、接続の健康を検証します。
• クライアントを圧倒しないように、同時サブスクリプションの数を制限します。

各接続は、1つのシンボルのみを購読できます。複数のペアを監視するには、それぞれの個別のWebSocketインスタンスを確立します。

よくある質問

複数の取引ペアを同時に購読するにはどうすればよいですか？複数のシンボルのデータを受信するには、各取引ペアの個別のWebSocket接続を開きます。たとえば、 BTCUSD ETHUSDは1つの接続を使用し、別の接続を使用します。単一のソケットに複数のシンボルのブロードキャストモードはありません。

変更配列の「0」量は何を意味しますか？変更フィールドの「0.0」の量は、対応する価格レベルが注文帳から削除されたことを示しています。たとえば、 ['sell', '65001.50', '0.0']は、 65001.50での質問が完全に埋められているかキャンセルされたことを意味します。

WebSocketフィードにアクセスするには認証が必要ですか？いいえ、パブリックマーケットデータWebSocketフィードでは、APIキーや認証は必要ありません。すべてのユーザーがアクセスできます。ただし、プライベートフィード（注文ステータスなど）には、Gemini Exchange APIを介して認証されたWebsocket接続が必要です。

ハートビートメッセージはどのくらいの頻度で送信されますか？ハートビートメッセージは、約5秒ごとに送信されます。 type: 'heartbeat'フィールドが含まれており、接続がアクティブであり、メッセージがリアルタイムで配信されていることを確認するために使用できます。