データ統合

トレーディングエンジンのリードレプリカ

アルゴリズミックトレーディングエンジンは、マイクロ秒単位まで最適化されたブラックボックスです。監視、分析、下流の利用者のためにサービスする各クエリは、取引パスからサイクルを奪い、低遅延トレーディングではサイクルこそがお金です。3forgeはそのエンジンの前段にリードレプリカとして位置します。エンジンの完全なデータ排出を無視できる影響で取り込み、隣接するすべてのシステムをエンジンではなくキャッシュから提供します。ホットパスは手つかずのまま保たれ、それでもすべての利用者は必要なデータを得られます。

課題

代償なしにホットパスを照会することはできない

エンジンはマイクロ秒単位まで調整されているため、外部リクエストに応える作業(ポジションをポーリングするリスクシステム、約定を購読するダッシュボード、取引を取得する分析ジョブ)はいずれも取引パスと競合します。直接読み取るシステムが増えるほど、そのホットパスへの負担は大きくなります。

パフォーマンスこそが製品

超低遅延トレーディングでは、マイクロ秒が約定品質とPnLを左右するため、監視やデータ配信のために加わる負荷はそのまま優位性を削ります。

すべての利用者が同じデータを欲しがる

リスク、サーベイランス、照合、ダッシュボード、分析はいずれもエンジンの注文、約定、ポジションを必要とし、それぞれをエンジンに向けると、最も負荷を吸収しにくいコンポーネントに負荷が集中します。

エンジンはブラックボックス

それは手作業で最適化されたC++システムで、独自の条件でデータを公開するため、そのホットパスにクエリ提供やデータベースを追加することは設計に反します。

多数の直接利用者

各チームがそれぞれの方法でエンジンに直接接続するにつれ、それらの依存関係はリスクなしにガバナンス、スロットリング、変更することが難しくなります。

3forgeのアプローチ

負荷を吸収するリードレプリカ

3forgeはトレーディングエンジンと並行して、保護的なデータ層として稼働します。エンジンはその活動を低オーバーヘッドの排出(マルチキャストタップ、ジャーナル、ファイア・アンド・フォーゲットの発行)として一度だけ出力し、3forgeはそれをペタバイト規模のカラムストアに裏打ちされたリアルタイムのインメモリテーブルに取り込みます。隣接するすべてのシステム(リスク、サーベイランス、照合、ダッシュボード、分析)は、エンジンではなく3forgeからデータを取得します。3forge Gatewayは、これらの利用者がすでに話しているほぼすべてのアクセスパターンを通じてそのデータを公開するため、エンジンはちょうど1つの利用者に対応するだけで、それ以外はすべて大規模に提供されます。ホットパスは保護され、データはエンジン自身が提供できるよりも新鮮で照会しやすくなります。

主な機能

3forgeで実現できること

最小影響のキャプチャ

マルチキャスト、ジャーナル、一方向の発行を通じてエンジンの排出をタップし、取り込みのオーバーヘッドを無視できる程度に抑え、取引パスを決してブロックしたりバックプレッシャーをかけたりしないようにします。

リアルタイムのシャドウテーブル

エンジンの注文、約定、ポジションを、フィード速度で更新されるインメモリテーブルにミラーリングし、すべての利用者にエンジン状態のライブで照会可能なコピーを提供します。

あらゆるアクセスパターンに対応

同じデータをSQL、ストリーミングサブスクリプション、REST、ODBC、Pythonを通じて公開し、各システムがすでに使用しているインターフェースをエンジンに変更を加えることなく維持できるようにします。

エンジン上の利用者は1つだけ

多数の直接依存を単一のタップに集約します。エンジンは3forgeのみに提供し、数百の利用者へのファンアウトはキャッシュに対して行われます。

オンタップの履歴の深さ

排出をペタバイト規模の履歴データベースに保持することで、バックテスト、サーベイランス、監査がライブエンジンに一切触れることなく数兆行を照会できます。

ガバナンスされた権限付き配信

権限、スロットリング、監査をGatewayで適用し、データ配信をガバナンスされていないポイント・ツー・ポイントのリンクではなく中央で制御します。

お問い合わせ

ホットパスを守り、データを解放する。

3forgeのソリューションエンジニアによる30分間のデモを予約し、リードレプリカがライブのエンジンデータをすべての下流システムへ一度に提供する様子をご覧ください。