Panduan Memulai Cepat Parsed Streams

Baru mengenal Parsed Streams? Baca model mentalnya terlebih dahulu — bagian tersebut menjelaskan alasan filter memiliki struktur seperti ini.

Panduan Memulai Cepat

Get Access

Parsed Streams tersedia pada semua paket dengan biaya 1 kredit per peristiwa yang dikirimkan. Dapatkan kunci API Anda dari Dasbor Helius, lalu hubungkan ke endpoint Gatekeeper di wss://beta.helius-rpc.com, host yang sama dengan lalu lintas RPC dan WebSocket Helius.Lakukan autentikasi dengan kunci API proyek Anda, yang diteruskan sebagai parameter kueri api-key (atau header x-api-key).

Connect

wscat

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

Kunci yang tidak ada atau tidak valid akan ditolak dengan HTTP 401. Proyek yang telah mencapai batas koneksinya akan menerima HTTP 429.

Subscribe with a Filter

Kirim parsedTransactionSubscribe dengan filter dan opsi opsional:

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

result dalam respons adalah bilangan bulat ID langganan:

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

Read a Notification

Setiap transaksi yang cocok diterima sebagai parsedTransactionNotification yang telah didekode, dengan matchedIndexes yang menunjuk ke instruksi yang cocok dengan filter Anda. Lihat Notifikasi untuk struktur lengkapnya.

Unsubscribe

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

Atau cukup tutup koneksi — tindakan ini akan menghapus semua langganannya.

Panduan

Track Jupiter Swaps

Gunakan describeProgram untuk membuat filter yang dapat Anda percayai sebelum berlangganan.

Track Pump.fun Mints

Listener yang aman terhadap koneksi ulang dan mencatat setiap penerapan token Pump.fun baru.

Handling Reconnects

Tangani batas waktu saat tidak aktif dan penerapan, lalu lakukan backfill secara tepat untuk data yang terlewat.

Referensi Protokol

Parsed Streams menggunakan JSON-RPC 2.0 melalui satu koneksi WebSocket. Setiap permintaan menerima respons dengan id yang sama. Langganan kemudian mengirim pesan parsedTransactionNotification hingga Anda berhenti berlangganan atau memutuskan koneksi.

Metode	Tujuan
`parsedTransactionSubscribe`	Memulai langganan dengan filter
`parsedTransactionUnsubscribe`	Menghentikan langganan
`describeProgram`	Mencantumkan instruksi, peristiwa, dan peran akun suatu program

{
  "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 }

Kolom filter

Setidaknya salah satu dari programs atau accounts.include wajib diisi. Kolom yang Anda tetapkan digabungkan dengan AND: sebuah instruksi harus memenuhi semuanya agar dianggap cocok.

string[]

ID program yang akan dicocokkan (alamat base58, bukan nama). Sebuah instruksi cocok jika programnya ada dalam daftar ini. OR berlaku di dalam daftar.

string[]

Nama instruksi yang telah didekode, seperti route. Nama pertama-tama dicocokkan secara persis, lalu menggunakan pencocokan cadangan yang tidak peka terhadap kapitalisasi dan pemisah. Karena itu, sharedAccountsRoute juga cocok dengan nama wire shared_accounts_route. OR berlaku di dalam daftar. Hanya instruksi yang namanya dapat diidentifikasi oleh katalog yang bisa cocok. Oleh karena itu, ambil nama dari describeProgram.

string[]

Alamat akun. Sebuah instruksi cocok jika salah satu alamat ini muncul dalam daftar akunnya. OR berlaku di dalam daftar. Berlaku untuk setiap instruksi, baik yang didekode maupun tidak. ID program itu sendiri tidak dihitung sebagai akun di sini.

object

Pemetaan nama peran akun yang telah didekode ke alamat, seperti { "user_transfer_authority": "<pubkey>" }. Setiap entri harus terpenuhi (AND di seluruh entri), dan instruksi harus didekode agar aturan ini dapat diterapkan. Nama peran dicocokkan secara persis, tanpa penyeragaman kapitalisasi. Jadi, salin nama dari describeProgram dan jangan menebaknya.

boolean

default:"false"

Sertakan instruksi dari transaksi yang gagal.

boolean

default:"true"

Instruksi internal (CPI) dapat dicocokkan. Tetapkan false untuk hanya mencocokkan instruksi tingkat teratas.

Kolom yang tidak dikenal di mana pun dalam filter atau opsi akan ditolak dengan -32602 dan tidak diabaikan secara diam-diam. Dengan demikian, kesalahan ketik akan langsung menghasilkan kegagalan, bukan filter yang tidak cocok dengan apa pun.

Opsi

Parameter kedua bersifat opsional.

string

default:"confirmed"

Hanya confirmed yang didukung.

string

default:"full"

Data yang dibawa setiap notifikasi. full: seluruh transaksi, setiap instruksi, serta matchedIndexes yang menunjuk ke kecocokan filter. matched: hanya instruksi yang cocok, tanpa daftar indeks. raw: hanya instruksi yang cocok, masing-masing disederhanakan menjadi posisinya, programId, dan blob data base58, tanpa kolom yang didekode dan tanpa larik accountKeys. Gunakan matched ketika bandwidth lebih penting daripada konteks (ukuran payload lengkap rata-rata sekitar tiga kali lebih besar), dan raw ketika Anda mendekode sendiri data instruksi dan hanya memerlukan byte-nya.

Jumlah koneksi serentak per proyek bergantung pada paket Anda: 5 untuk Free, 10 untuk Developer, serta 50 untuk Business dan Professional, yang digunakan bersama oleh semua kunci API proyek. Lihat Batas Laju.

Notifikasi

Satu notifikasi per transaksi yang cocok untuk setiap langganan. Dengan details: "full" default:

{
  "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]
      }
    }
  }
}

Cara membacanya:

transaction adalah konteks lengkap. fee dinyatakan dalam lamport. accountKeys adalah daftar kunci lengkap, termasuk kunci yang dimuat dari tabel pencarian alamat, dalam urutan yang sama seperti yang dilaporkan oleh chain. feePayer selalu bernilai accountKeys[0]. error memuat kesalahan transaksi sebagai JSON terstruktur, misalnya {"InstructionError": [2, {"Custom": 6001}]}, ketika status bernilai "error".
summary memiliki satu struktur yang sama di setiap kemunculannya: type (seperti swap atau transfer), description yang mudah dibaca manusia, serta payload parsedData terstruktur ketika parser mengenali tindakan tersebut — untuk swap: protokol, jumlah, dan mint. transaction.summary menandai tindakan utama transaksi; setiap instruksi yang dikenali memiliki summary sendiri dengan struktur yang sama. Untuk mengumpulkan setiap swap dalam transaksi, iterasikan instructions dan baca summary.parsedData ketika summary.type bernilai "swap".
nativeTransfers dan tokenTransfers mencantumkan perpindahan SOL dan token yang diekstrak parser dari seluruh transaksi, dengan struktur yang sama seperti yang dikembalikan API Parsed Events. Dengan demikian, konsumen stream dan API dapat menggunakan kode pemrosesan yang sama. Keduanya selalu ada, tetapi mungkin kosong.
instructions berisi setiap instruksi transaksi dalam urutan eksekusi: setiap instruksi tingkat teratas diikuti instruksi internalnya. Setiap entri memiliki posisinya sendiri: instructionIndex menunjukkan instruksi tingkat teratas yang menaunginya (dimulai dari 0), innerInstructionIndex menunjukkan posisinya di antara panggilan internal instruksi tersebut (null berarti entri tersebut adalah instruksi tingkat teratas itu sendiri), dan stackHeight adalah kedalaman panggilan (1 untuk tingkat teratas). Gunakan nilai-nilai ini, bukan posisi lariknya.
matchedIndexes adalah indeks ke dalam instructions yang menunjukkan instruksi mana yang benar-benar cocok dengan filter Anda. Instruksi lainnya disertakan sebagai konteks. Dengan details: "matched", larik hanya berisi instruksi yang cocok dan matchedIndexes tidak ada.
Nama decoded menggunakan snake_case (in_amount, user_transfer_authority), sebagaimana dipublikasikan dalam IDL program. Argumen bilangan bulat biasanya berupa string ("1000000") karena nilai u64 tidak dapat ditampung dalam angka JavaScript.
blockTime saat ini selalu bernilai null. Jangan mengandalkannya.
Dalam satu transaksi, Anda dapat menemukan campuran instruksi yang didekode dan tidak didekode: swap yang sepenuhnya didekode dapat muncul di samping memo yang tidak dikenali. Buat percabangan berdasarkan decoded: ketika nilainya null, instruksi tersebut membawa rawData (byte base58) dan rawAccounts (daftar pubkey biasa) sebagai gantinya. Dengan demikian, Anda selalu memiliki data yang dapat diproses.

Dengan details: "raw", value menyusut menjadi metadata transaksi dan blob. accountKeys, nativeTransfers, tokenTransfers, matchedIndexes, dan semua kolom yang didekode dihapus (summary transaksi tetap disertakan); setiap instruksi yang cocok berisi posisinya, programnya, dan byte data dalam base58, persis seperti yang muncul pada chain (tetap ada bahkan untuk instruksi yang sebenarnya dapat didekode oleh katalog):

"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" }
  ]
}

Berhenti Berlangganan

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

Mengembalikan true jika langganan tersebut ada dan merupakan milik Anda. Notifikasi langsung berhenti. Menutup koneksi akan menghapus semua langganannya.

Penemuan

Kegagalan paling umum pada API semacam ini adalah filter yang valid tetapi tidak cocok dengan apa pun, biasanya karena nama instruksi atau peran ditebak. describeProgram mencegah hal tersebut dengan mengembalikan nama persis yang dibandingkan oleh pencocok. Saat ini, metode tersebut hanya tersedia pada wss://fs-beta.helius-rpc.com/?api-key=<API_KEY>. Jadi, kirim melalui koneksi terpisah dari langganan Anda:

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"]
  }
}

Anda dapat meneruskan alamat program atau nama katalog, tetapi utamakan alamat: nama dapat ambigu di berbagai versi program (lebih dari satu entri katalog bernama jupiter, dan pencarian berdasarkan nama dapat mengarah ke entri yang lebih lama). Jika Anda melakukan pencarian berdasarkan nama, pastikan result.id adalah program yang ingin Anda langgani. Alur yang disarankan: gunakan describeProgram untuk mendapatkan nama instruksi dan peran yang persis, buat filter dengan nama tersebut, lalu berlangganan. Panduan Melacak Swap Jupiter menjelaskan proses ini dari awal hingga akhir.

Batas

Batas	Nilai
Koneksi serentak per proyek	5 (Free), 10 (Developer), 50 (Business dan Professional)
Langganan per koneksi	25
Pesan klien	10 per detik, lonjakan hingga 20
Ukuran pesan klien	64 KiB
`programs` per filter	10
`instructionNames` per filter	50, masing-masing hingga 64 karakter
`accounts.include` per filter	100
`accounts.roles` per filter	20, setiap nama hingga 64 karakter
Buffer keluar per koneksi	2048 notifikasi, kemudian koneksi ditutup

Kesalahan

Kesalahan mengikuti JSON-RPC 2.0: { "error": { "code": <int>, "message": "<text>" }, "id": <id> }. Pesan menjelaskan secara persis apa yang salah dan lokasinya.

Kode	Arti
`-32700`	Kesalahan penguraian (JSON tidak valid)
`-32600`	Permintaan tidak valid
`-32601`	Metode tidak ditemukan
`-32602`	Parameter tidak valid: pubkey salah, kolom tidak dikenal, commitment tidak didukung, atau nilai details tidak didukung
`-32000`	Batas filter terlampaui
`-32001`	Server belum siap; coba lagi dengan backoff
`-32002`	Terkena batas laju (10 pesan per detik)
`-32006`	Terlalu banyak langganan (25 per koneksi)

Koneksi juga dapat ditutup dengan kode penutupan WebSocket — lihat Menangani Koneksi Ulang untuk mengetahui arti setiap kode dan cara memulihkan koneksi.

Contoh Klien

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())

Memulai

Streaming Data & Pemantauan Peristiwa

API Data & RPC

Perdagangan

Mengirim Transaksi

Dompet sebagai Layanan

Privasi

Sumber Daya

Panduan Memulai Cepat Parsed Streams