accountSubscribe RPC Method

Parameters

Pubkey

string

The public key of account to query encoded as base-58 string

object

array

The configuration object with the following fields:

commitment

string

The level of commitment required for the query. The options include:

finalized

string

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

confirmed

string

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

processed

string

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

encoding

string

The encoding format for account data. It can be one of base58 (slow), base64, base64+zstd or jsonParsed

Returns

result

integer

The result will be an RpcResponse JSON object with id equal to the subscription id (needed to unsubscribe)

Notification Format:

The notification format is the same as seen in the getAccountInfo RPC HTTP method

Request

import { address, createSolanaRpcSubscriptions } from '@solana/kit';

const rpcSubscriptions = createSolanaRpcSubscriptions('');

async function main() {
    const abortController = new AbortController();
    const accountNotifications = await rpcSubscriptions
        .accountNotifications(address('9kwU8PYhsmRfgS3nwnzT3TvnDeuvdbMAXqWsri2X8rAU'), { commitment: 'confirmed' })
        .subscribe({ abortSignal: abortController.signal });

    try {
        for await (const notification of accountNotifications) {
            console.log('New balance', notification.value.lamports);
        }
    } catch (e) {
        console.error(e);
    }

}

main();

const web3 = require("@solana/web3.js");
(async () => {
  const publicKey = new web3.PublicKey(
    "E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"
  );
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
    wsEndpoint: "",
  });
  solanaConnection.onAccountChange(
    publicKey,
    (updatedAccountInfo, context) =>
      console.log("Updated account info: ", updatedAccountInfo),
    "confirmed"
  );
})();

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("") as websocket:
        await websocket.account_subscribe(PublicKey('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk'))
        first_resp = await websocket.recv()
        subscription_id = first_resp.result
        async for idx, msg in enumerate(websocket):
            print(msg)

asyncio.run(main())

wscat -c  \ 
# wait for connection 
{"id":1,"jsonrpc":"2.0","method":"accountSubscribe","params":["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk",{"encoding": "jsonParsed"}]}

Response

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

Don't have an account yet?

Create your QuickNode endpoint in seconds and start building

Get started for free