Solanaでのデータストリーミングとは?
データストリーミングにより、アプリケーションはチェーン上でイベントが発生する際にSolanaブロックチェーンからリアルタイムで更新を受け取ることができます。更新を繰り返しポーリングする代わりに、ストリーミングは永続的な接続を確立し、トランザクションが処理されたりアカウントが変更されたりブロックが生成されたりすると、データをアプリケーションに即時にプッシュします。 これは、次のような即時データを必要とするアプリケーションにとって重要です:- 取引アプリケーション 価格変動や清算を監視
- DeFiプロトコル ユーザーのインタラクションや状態変化を追跡
- NFTマーケットプレイス 売買、リスト、転送を検出
- 分析プラットフォーム 包括的なブロックチェーンメトリックを収集
- ウォレット リアルタイムの残高とトランザクションの更新を表示
データストリーミングにHeliusを選ぶ理由
超低レイテンシー
Solanaリーダーへの直接接続により、サブセカンドでのデータ配信を実現
エンタープライズの信頼性
多ノードの冗長性と自動フォールオーバーで99.9%の稼働率を保証
24時間履歴再生
自動バックフィル機能でデータを逃しません
グローバルインフラ
世界中の複数の地域にエンドポイントを持ち、最適なパフォーマンスを実現
どのストリーミングソリューションを使うべきか?
必要なデータの段階とアプリがそれを消費したい方法に合った製品を選びます。以下の表は、各オプションとその配信形状、および最適なワークロードの種類をマッピングしています。最適化の目的で選ぶ
シュレッドベースの製品とLaserStreamのコミットメントレベルはトランザクションライフサイクルの異なるポイントに位置します。受け取りたいものはプロトコルと同様に重要です:よくある間違い: リアルタイムのアカウントやプログラムの状態変化が必要な場合(例:AMMのボンディングカーブアカウントやユーザーのトークン残高の監視)、Shred Deliveryは役に立ちません — それらの更新はシュレッド段階では存在しません。LaserStream gRPC at
processedを使用してください。Heliusストリーミングソリューション
Preconfirmations
Preconfirmationsは、取引が最初に観察できる瞬間、つまりバリデーターのスケジューラーが実行を確定した瞬間にストリーミングされます。シュレッド処理される前の最も低遅延な取引シグナルを、プロフェッショナルプラン以上の加入者には10クレジット/メッセージで提供します。最適な用途
オンチェーン活動に対する最も早い反応:- propAMMs
- スナイパー
- コピー・トレーダー
- 清算ボット
プレコンファメーションは初期のシグナルであり、保証ではありません — 取引はまだ確定しておらず、失敗または削除される可能性があります。
Shred Delivery
Shred Delivery はHeliusの事前実行データ製品です: 生シュレッド (UDP)。Heliusはステークによるトップバリデータなので、低ステークのバリデータやノンステークのRPCノードよりも早くシュレッドを受け取ります。シュレッド解除は自分で実装します。すべてのプランで利用可能で、各シートはIPごとに月額1,000ドル(Proプランでは月額800ドル)。Heliusダッシュボードで購読 - 手動のプロビジョニングは不要です。最適な用途
- propAMMs
- スナイパー
- コピートレーダー
- 清算ボット
- アービトラージ
- ネットワーク同期遅延を排除したいRPCノードオペレーター
前処理済みトランザクション
前処理済みトランザクションは、主にデコードされたシュレッドから集約された事前実行トランザクションで、シュレッド解除はHeliusが担当します。preprocessedSubscribe WebSocket を通じて提供されます (パブリックベータ、すべての有料プラン、メッセージごとに0.1クレジット)。以前のgRPC提供 (プロフェッショナルプラン、1 MBごとに20クレジット) はその代わりに廃止されます。
最適な用途
シュレッドデコーダーを操作せずにデコードされた事前実行トランザクションを求める低遅延トレーディングアプリケーション。LaserStream gRPC (Devnet すべてのプラン、メインネットのビジネス+)
LaserStream gRPC は gRPC を介した超低遅延データストリーミングを提供し、ヒストリカルリプレイ、自動再接続、マルチノードの信頼性などの高度な機能を備えています。LaserStreamはオープンなYellowstone gRPCプロトコルと互換性があるため、どのYellowstoneクライアントも動作します。主な機能
- 簡単導入: ハードウェアやアップグレードの管理に頭を悩ませずにより早いgRPCストリームを取得
- 24時間履歴再生: 最大24時間の欠損データを自動的にバックフィル
- 自動再接続: インテリジェントリトライロジックを備えた内蔵接続管理
- グローバルエンドポイント: 世界中の9つの地域で利用可能で最適な遅延を実現
- Yellowstone互換: 既存の
@triton-one/yellowstone-grpc設定の代替品として使用可能
最適な用途
- バックエンドサービス
- 高スループットアプリケーション
- データ配信を保証する必要があるミッションクリティカルシステム
LaserStream WebSocket
LaserStream WebSocket はLaserStreamのWebSocketプロトコルバリアントです。標準のSolana JSON-RPCサブスクリプションメソッド(accountSubscribe、programSubscribe、logsSubscribe、…)とHelius特有の拡張機能transactionSubscribeを、同じ統合エンドポイントで同一のLaserStreamバックエンドで提供します。
主な機能
- 完全なSolana互換性: 任意のSolana WebSocketクライアントライブラリで動作します
- Helius拡張機能:
transactionSubscribeと強化されたaccountSubscribeによりリッチなフィルタリングが可能 - 標準のAgave RPCベースWebSocketより最大で200ms速い
- 統合エンドポイント: 通常およびHelius拡張メソッドに対応する
wss://mainnet.helius-rpc.comとwss://devnet.helius-rpc.com
最適な用途
リアルタイムフロントエンドアプリ、中ボリュームのバックエンド、広範なエコシステム互換性Webhooks
オンチェーンアクティビティのイベント駆動型サーバー間Webhook通知をエンドポイントに配信します。主な機能
- 解析済みイベントデータ: 販売、スワップなどの人間が読めるトランザクションデータ
- 複数のタイプ: 強化済み、生データ、DiscordのWebhookオプション
- トランザクションフィルタリング: 特定のイベントタイプやアドレスに登録
- 信頼できる配信: 自動再試行と配信確認
最適な用途
イベント駆動型アーキテクチャ、通知、外部サービスとの統合始めに
1
ソリューションを選ぶ
アプリの要件とインフラに最適なストリーミング方法を選択します。
2
APIキーを取得する
dashboard.helius.dev にサインアップして
APIキーを取得してください。
3
クイックスタートを実行する
各ソリューションには専用のクイックスタートガイドとコード例があります。
4
監視とスケーリング
Heliusダッシュボードを使用して使用状況を監視し、必要に応じてプランをスケールします。
データストリーミングクイックスタート
数分で最初のストリーミング接続を設定して動作させましょう
サポートとコミュニティ
ドキュメント
すべてのストリーミング方法に関する包括的なAPIリファレンスとガイド
Discordコミュニティ
Heliusを使用してSolana上で開発している数千人の開発者に参加しましょう
エンタープライズサポート
ビジネスおよびプロフェッショナル顧客向けの優先サポートチャンネル