Parsed Streams クイックスタート

Parsed Streams が初めてですか？まずメンタルモデルを読んでください。フィルターがなぜそのように見えるのかを説明しています。

クイックスタート

Get Access

Parsed Streams は、配信イベントあたり 1 クレジットですべてのプランで利用できます。Helius Dashboard から API キーを取得し、Helius RPC および WebSocket トラフィックと同じホストである wss://beta.helius-rpc.com の Gatekeeper エンドポイントに接続します。認証は、あなたのプロジェクトの API キーを api-key クエリパラメータ（または x-api-key ヘッダー）として渡します。

接続

wscat

wscat -c "wss://beta.helius-rpc.com/?api-key=YOUR_API_KEY"

不足または無効なキーはHTTP 401で拒否されます。接続上限に達したプロジェクトはHTTP 429を受け取ります。

フィルターでサブスクライブ

フィルターとオプションのオプションを指定して parsedTransactionSubscribe を送信します。

{"jsonrpc":"2.0","id":1,"method":"parsedTransactionSubscribe","params":[{"programs":["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"]}]}

応答 result は整数のサブスクリプション ID です。

{ "jsonrpc": "2.0", "id": 1, "result": 23 }

通知を読む

マッチするトランザクションはすべて、すでにデコードされた parsedTransactionNotification として到着し、フィルターがヒットした命令を指す matchedIndexes が含まれています。完全な形式は通知を参照してください。

サブスクライブ解除

{ "jsonrpc": "2.0", "id": 2, "method": "parsedTransactionUnsubscribe", "params": [23] }

または接続を閉じるだけで、すべてのサブスクリプションが削除されます。

ガイド

Jupiter Swaps を追跡

信頼できるフィルターを構築するために describeProgram を使用します。

Pump.fun Mints を追跡

各新しい Pump.fun トークンを記録する再接続対応のリスナーです。

再接続処理

アイドルタイムアウトやデプロイを乗り越え、見逃したものを正確に補完します。

プロトコルリファレンス

Parsed Streams は、単一の WebSocket 接続を通じて JSON-RPC 2.0 を使用します。各リクエストは同じ id に応じて応答します。サブスクリプションは、サブスクライブ解除または切断があるまで parsedTransactionNotification メッセージをプッシュします。

メソッド	目的
`parsedTransactionSubscribe`	フィルターを使用してサブスクリプションを開始する
`parsedTransactionUnsubscribe`	サブスクリプションを停止する
`describeProgram`	プログラムの命令、イベント、アカウントロールを一覧表示する

サブスクライブ

フィルターとオプションを使用して parsedTransactionSubscribe を送信します。応答 result は整数のサブスクリプション ID です。

Request

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "parsedTransactionSubscribe",
  "params": [
    {
      "programs": ["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"],
      "instructionNames": ["route", "shared_accounts_route"],
      "accounts": {
        "include": ["So11111111111111111111111111111111111111112"],
        "roles": { "user_transfer_authority": "9xQeWvG816bUx9EPjHmaT23yvVM2ZWbrrpZb9PusVFin" }
      },
      "includeFailed": false,
      "includeCpi": true
    },
    { "commitment": "confirmed", "details": "full" }
  ]
}

Response

{ "jsonrpc": "2.0", "id": 1, "result": 23 }

フィルターフィールド

programs または accounts.include のいずれかが必要です。設定したフィールドは AND で結合されます：命令はすべてを満たす必要があります。

string[]

一致させるプログラムID（base58アドレス、名前ではありません）。インストラクションがこのリストにあるプログラムの場合に一致します。リスト内のOR。

string[]

デコードされたインストラクション名。最初に完全一致し、その後大文字と小文字を区別しないフォールバックが行われます。カタログが識別できる名前のインストラクションのみ一致しますので、名前はdescribeProgramから取ってください。

string[]

アカウントアドレス。これらのいずれかがアカウントリストに登場すればインストラクションが一致します。リスト内のOR。デコードされていないインストラクションにも機能します。プログラムID自体はここではアカウントとみなされません。

object

デコードされたアカウントロール名からアドレスへのマップ。各エントリが保持される必要があります（エントリ間でAND）。インストラクションがデコードされている必要があります。ロール名は正確に一致する必要があるので、describeProgramからコピーしてください。

boolean

デフォルト:"false"

失敗したトランザクションのインストラクションを含めます。

boolean

デフォルト:"true"

内部（CPI）インストラクションが一致対象です。トップレベルのインストラクションのみを一致させるにはfalseを設定します。

フィルターまたはオプション内の不明なフィールドは -32602 で拒否され、無視される代わりに何もマッチしません。

オプション

2番目のパラメータはオプションです。

string

デフォルト:"confirmed"

confirmed のみがサポートされています。

string

デフォルト:"full"

各通知に含まれる内容。full：トランザクション全体、すべての命令、フィルターヒットを指す matchedIndexes を含みます。matched：一致した命令のみ、インデックスリストなし。raw：一致した命令のみ、その位置に還元されて、それぞれの programId、base58 の data バイト、デコードされたフィールドなし、accountKeys 配列なし。帯域幅がコンテキストよりも重要な場合は matched、命令データを自分でデコードし、バイトのみを必要とする場合は raw を使用します。

プロジェクトごとの同時接続数はプランによって異なります。Free では 5、Developer では 10、Business および Professional では 50 で、プロジェクトのすべての API キーで共有されます。レート制限を参照してください。

通知

サブスクリプションごとに一致するトランザクションごとの通知。デフォルトの details: "full" とともに：

{
  "jsonrpc": "2.0",
  "method": "parsedTransactionNotification",
  "params": {
    "subscription": 23,
    "result": {
      "context": { "slot": 430172053 },
      "value": {
        "transaction": {
          "signature": "3riSYL4HTRxgQjLayt6L2JPaDR3oaEQg1H4v3fnjUxNU...",
          "slot": 430172053,
          "blockTime": null,
          "feePayer": "6jduWNCTQzG91JGBchfGGxd55Vi5FxJCCJEV18RkXzJX",
          "fee": 5000,
          "accountKeys": ["6jduWNCT...", "..."],
          "status": "ok",
          "error": null,
          "summary": {
            "type": "swap",
            "description": "6jduWNCTQzG91JGBchfGGxd55Vi5FxJCCJEV18RkXzJX swapped 0.001 SOL for 0.183985 EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v via Jupiter",
            "parsedData": {
              "type": "swap",
              "protocol": "jupiter",
              "kind": "swap",
              "in_amount": "1000000",
              "actual_out_amount": "183985",
              "input_mint": "So11111111111111111111111111111111111111112",
              "output_mint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"
            }
          },
          "nativeTransfers": [
            { "fromUserAccount": "6jduWNCT...", "toUserAccount": "DfXygSm4...", "amount": 1000000 }
          ],
          "tokenTransfers": [
            {
              "fromUserAccount": "6jduWNCT...",
              "toUserAccount": "AeUfFU6L...",
              "fromTokenAccount": "HLaEoW1s...",
              "toTokenAccount": "G13P9kSY...",
              "rawTokenAmount": 183985,
              "decimals": 6,
              "tokenStandard": "Fungible",
              "mint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"
            }
          ]
        },
        "instructions": [
          {
            "instructionIndex": 4,
            "innerInstructionIndex": null,
            "stackHeight": 1,
            "programId": "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4",
            "programName": "jupiter",
            "instructionName": "route",
            "summary": {
              "type": "swap",
              "description": "6jduWNCTQzG91JGBchfGGxd55Vi5FxJCCJEV18RkXzJX swapped 0.001 SOL for 0.183985 EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v via Jupiter",
              "parsedData": {
                "type": "swap",
                "protocol": "jupiter",
                "kind": "swap",
                "in_amount": "1000000",
                "actual_out_amount": "183985",
                "input_mint": "So11111111111111111111111111111111111111112",
                "output_mint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"
              }
            },
            "decoded": {
              "args": { "in_amount": "1000000", "slippage_bps": 50 },
              "accounts": [
                { "name": "user_transfer_authority", "pubkey": "9xQe...", "isSigner": true, "isWritable": false }
              ]
            }
          }
        ],
        "matchedIndexes": [8, 13]
      }
    }
  }
}

これを読む：

transaction は完全なコンテキストです。fee の単位は lamports です。accountKeys は、アドレスルックアップテーブルから読み込まれたキーを含む完全なキーリストであり、チェーンから報告される順序と同じです。feePayer は常に accountKeys[0] です。error は、status が "error" の場合に、トランザクションエラーを構造化 JSON として保持します（例：{"InstructionError": [2, {"Custom": 6001}]}）。
summary は、表示されるすべての箇所で同じ構造です。type（swap や transfer など）、人が読める description、およびパーサーがアクションを認識した場合の構造化された parsedData ペイロードで構成されます。スワップの場合は、プロトコル、数量、ミントが含まれます。transaction.summary はトランザクションの主要なアクションを示します。認識された各命令には、同じ構造の独自の summary が含まれます。トランザクション内のすべてのスワップを収集するには、instructions を反復処理し、summary.type が "swap" である箇所の summary.parsedData を読み取ります。
スワップ数量は取引プラットフォームから報告された値です。 in_amount、actual_out_amount、および parsedData 内の内部スワップ数量は、ユーザーのウォレットが実際に送受信した数量ではなく、取引プラットフォームから報告された値です。Token-2022 の送金手数料や、スワップ外で適用されるその他の控除は考慮されていません。正確な受取数量を確認するには、トランザクション前後のユーザーのトークンアカウント残高を比較します。
nativeTransfers と tokenTransfers は、パーサーがトランザクション全体から抽出した SOL とトークンの移動を、Parsed Events API が返すものと同じ構造で一覧表示します。そのため、ストリームと API の利用側で処理コードを共有できます。どちらも常に存在しますが、空の場合があります。
instructions には、トランザクションのすべての命令が実行順に含まれます。各トップレベル命令の後に、その内部命令が続きます。各エントリには独自の位置情報が含まれます。instructionIndex は、そのエントリが属するトップレベル命令を示します（0 から開始）。innerInstructionIndex は、その命令の内部呼び出し内での位置を示します（null の場合はトップレベル命令自体を意味します）。stackHeight は呼び出しの深さです（トップレベルは 1）。配列内の位置ではなく、これらを使用してください。
matchedIndexes は instructions へのインデックスであり、フィルターに実際に一致した命令を示します。残りの命令はコンテキストとして含まれます。details: "matched" を使用すると、配列には一致した命令のみが含まれ、matchedIndexes は存在しません。
decoded の名前は snake_case です（in_amount、user_transfer_authority）。これはプログラムの IDL で公開されている形式です。u64 値は JavaScript の数値に収まらないため、整数引数は通常、文字列（"1000000"）です。
blockTime は現在、常に null です。これに依存しないでください。
1 つのトランザクション内に、デコード済み命令と未デコード命令が混在することを想定してください。完全にデコードされたスワップが、認識されていないメモの隣に存在する場合があります。decoded に基づいて分岐してください。これが null の場合、命令には代わりに rawData（base58 バイト）と rawAccounts（プレーンな公開キーリスト）が含まれるため、常に処理できるデータがあります。

details: "raw"を使用するとvalueはトランザクションメタとブロブに縮小されます。

"value": {
  "transaction": {
    "signature": "3riSYL4HTRxgQjLayt6L2JPaDR3oaEQg1H4v3fnjUxNU...",
    "slot": 430172053,
    "blockTime": null,
    "feePayer": "6jduWNCTQzG91JGBchfGGxd55Vi5FxJCCJEV18RkXzJX",
    "fee": 5000,
    "status": "ok",
    "error": null,
    "summary": {
      "type": "swap",
      "description": "6jduWNCTQzG91JGBchfGGxd55Vi5FxJCCJEV18RkXzJX swapped 0.001 SOL for 0.183985 EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v via Jupiter",
      "parsedData": {
        "type": "swap",
        "protocol": "jupiter",
        "kind": "swap",
        "in_amount": "1000000",
        "actual_out_amount": "183985",
        "input_mint": "So11111111111111111111111111111111111111112",
        "output_mint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"
      }
    }
  },
  "instructions": [
    { "instructionIndex": 4, "innerInstructionIndex": null, "stackHeight": 1, "programId": "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4", "data": "3Bxs4h24hBtQy9rw" }
  ]
}

サブスクライブ解除

{ "jsonrpc": "2.0", "id": 2, "method": "parsedTransactionUnsubscribe", "params": [23] }

サブスクリプションが存在し、自分のものであれば true を返します。通知は即座に停止します。接続を閉じるとすべてのサブスクリプションが削除されます。

発見

この種の API で最も一般的な失敗は、フィルター自体は有効でも何にも一致しないことです。通常は、命令名またはロール名を推測して指定したことが原因です。describeProgram は、マッチャーが比較する正確な名前を返すことで、この問題を防ぎます。現在は wss://fs-beta.helius-rpc.com/?api-key=<API_KEY> でのみ利用できるため、サブスクリプションとは別の接続で送信してください。

Request

{ "jsonrpc": "2.0", "id": 1, "method": "describeProgram", "params": [{ "program": "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4" }] }

Response

{
  "jsonrpc": "2.0", "id": 1,
  "result": {
    "id": "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4",
    "name": "jupiter",
    "instructions": ["route", "shared_accounts_route", "exact_out_route"],
    "events": ["SwapEvent"],
    "roles": ["user_transfer_authority", "destination_token_account"]
  }
}

プログラムアドレスまたはカタログ名を渡すことができますが、住所を優先してください：名前はプログラムバージョン間で曖昧になる可能性があります（複数のカタログエントリが同じ jupiter という名前を持ちます、名前検索は古いものを解決することがあります）。名前で検索する場合は、result.id がサブスクライブしようとしているプログラムであることを確認してください。推奨フロー：describeProgram を使用して正確な命令名とロール名を取得し、それらの名前を使用してフィルターを構築し、次にサブスクライブします。Track Jupiter Swaps ガイドはこれを端から端まで説明します。

制限

制限	値
プロジェクトごとの同時接続数	5（Free）、10（Developer）、50（Business および Professional）
接続ごとのサブスクリプション数	25
クライアントメッセージ	1 秒あたり 10、バースト時は 20
クライアントメッセージのサイズ	64 KiB
フィルターごとの `programs`	10
フィルターごとの `instructionNames`	50（それぞれ最大 64 文字）
フィルターごとの `accounts.include`	100
フィルターごとの `accounts.roles`	20（各名前は最大 64 文字）
接続ごとの送信バッファ	2048 件の通知。その後、接続が閉じられます

エラー

エラーは JSON-RPC 2.0 に従います：{ "error": { "code": <int>, "message": "<text>" }, "id": <id> }。メッセージは何が間違っていたか、どこで間違っていたかを正確に言います。

コード	意味
`-32700`	解析エラー（無効な JSON）
`-32600`	無効なリクエスト
`-32601`	メソッドが見つかりません
`-32602`	無効なパラメータ：不正な公開鍵、不明なフィールド、サポートされていないコミットメントまたは詳細値
`-32000`	フィルター制限を超過しました
`-32001`	サーバーが準備できていません；バックオフで再試行してください
`-32002`	レート制限されています（10 メッセージ毎秒）
`-32006`	サブスクリプションが多すぎます（接続ごとに 25）

接続はまた WebSocket クローズコードによって閉じられることがあります—それぞれが何を意味し、どのように回復するかについては再接続の処理を参照してください。

クライアント例

wscat -c "wss://beta.helius-rpc.com/?api-key=<API_KEY>"
# then send:
{"jsonrpc":"2.0","id":1,"method":"parsedTransactionSubscribe","params":[{"programs":["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"]}]}

import WebSocket from "ws";

const ws = new WebSocket("wss://beta.helius-rpc.com/?api-key=<API_KEY>");

ws.on("open", () => {
  ws.send(JSON.stringify({
    jsonrpc: "2.0",
    id: 1,
    method: "parsedTransactionSubscribe",
    params: [{ programs: ["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"] }],
  }));
});

ws.on("message", (data) => {
  const msg = JSON.parse(data.toString());
  if (msg.method === "parsedTransactionNotification") {
    const { transaction, instructions, matchedIndexes } = msg.params.result.value;
    for (const i of matchedIndexes ?? instructions.keys()) {
      const ix = instructions[i];
      console.log(transaction.signature, ix.programName, ix.instructionName, ix.decoded?.args);
    }
  }
});

import asyncio, json, websockets

URL = "wss://beta.helius-rpc.com/?api-key=<API_KEY>"

async def main():
    async with websockets.connect(URL) as ws:
        await ws.send(json.dumps({
            "jsonrpc": "2.0", "id": 1, "method": "parsedTransactionSubscribe",
            "params": [{"programs": ["JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"]}],
        }))
        async for raw in ws:
            msg = json.loads(raw)
            if msg.get("method") == "parsedTransactionNotification":
                value = msg["params"]["result"]["value"]
                for i in value.get("matchedIndexes") or range(len(value["instructions"])):
                    ix = value["instructions"][i]
                    print(ix.get("programName"), ix.get("instructionName"), (ix.get("decoded") or {}).get("args"))

asyncio.run(main())

はじめに

データストリーミングとイベントリスニング

データ API と RPC

取引

トランザクションの送信

Wallet-as-a-Service

プライバシー

リソース

Parsed Streams クイックスタート

クイックスタート

ガイド

Jupiter Swaps を追跡

Pump.fun Mints を追跡

再接続処理

プロトコルリファレンス

サブスクライブ

フィルターフィールド

オプション

通知

サブスクライブ解除

発見

制限

エラー

クライアント例

​クイックスタート

​ガイド

Jupiter Swaps を追跡

Pump.fun Mints を追跡

再接続処理

​プロトコルリファレンス

​サブスクライブ

​フィルターフィールド

​オプション

​通知

​サブスクライブ解除

​発見

​制限

​エラー

​クライアント例

クイックスタート

ガイド

プロトコルリファレンス

サブスクライブ

フィルターフィールド

オプション

通知

サブスクライブ解除

発見

制限

エラー

クライアント例