AptosAptos Network's breakthrough technology and seamless user experience are now available on QuickNode.

Start building today!     


programSubscribe RPC Method

The API credit value for this method is 1 . To learn more about API credits and each method's value, visit the API Credits page.


  1. program_id - Pubkey, as base-58 encoded string
  2. Object - (optional) Configuration object containing the following optional fields:

    Commitment - (optional) All fields are strings.

    Finalized - the node will query the most recent block confirmed by supermajority of the cluster as having reached maximum lockout, meaning the cluster has recognized this block as finalized.

    Confirmed - the node will query the most recent block that has been voted on by supermajority of the cluster.

    Processed - the node will query its most recent block. Note that the block may not be complete.

    encoding - encoding for Account data, either "base58" (slow), "base64", "base64+zstd", or "jsonParsed".

    filters - filter results using various filter objects; account must meet all filter criteria to be included in results.


  1. Result - The result will be an RpcResponse JSON object with id equal to:

    number - Subscription id (needed to unsubscribe)

Notification Format:

  1. Result - The notification format is the same as seen in the getProgramAccounts RPC HTTP method.

Code Examples:

import solana
import asyncio
from asyncstdlib import enumerate
from solana.rpc.websocket_api import connect
from solana.publickey import PublicKey

async def main():
    async with connect("wss://sample-endpoint-name.network.quiknode.pro/token-goes-here/") as websocket:
        await websocket.program_subscribe(PublicKey('22Y43yTVxuUkoRKdm9thyRhQ3SdgQS7c7kB6UNCiaczD'))
        first_resp = await websocket.recv()
        subscription_id = first_resp.result
        async for idx, msg in enumerate(websocket):

Ready to get started? Create a free account