accountSubscribe RPC Method

As of May 1, 2026, this WebSocket method is billed based on metered data usage: 0.1 MB = 15 API credits. Learn more about WebSocket billing.

Parameters

Pubkey

string

Loading...

object

object

Loading...

commitment

string

Loading...

finalized

string

Loading...

confirmed

string

Loading...

processed

string

Loading...

encoding

string

Loading...

Returns

result

integer

Loading...

Notification Format:

Loading...

Request

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

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

11
    try {
12
        for await (const notification of accountNotifications) {
13
            console.log('New balance', notification.value.lamports);
14
        }
15
    } catch (e) {
16
        console.error(e);
17
    }
18

19
}
20

21
main();

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

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

11
    try {
12
        for await (const notification of accountNotifications) {
13
            console.log('New balance', notification.value.lamports);
14
        }
15
    } catch (e) {
16
        console.error(e);
17
    }
18

19
}
20

21
main();

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const publicKey = new web3.PublicKey(
4
    "E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"
5
  );
6
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
7
    wsEndpoint: "",
8
  });
9
  solanaConnection.onAccountChange(
10
    publicKey,
11
    (updatedAccountInfo, context) =>
12
      console.log("Updated account info: ", updatedAccountInfo),
13
    "confirmed"
14
  );
15
})();
16

1
const web3 = require("@solana/web3.js");
2
(async () => {
3
  const publicKey = new web3.PublicKey(
4
    "E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"
5
  );
6
  const solanaConnection = new web3.Connection("https://docs-demo.solana-mainnet.quiknode.pro/", {
7
    wsEndpoint: "",
8
  });
9
  solanaConnection.onAccountChange(
10
    publicKey,
11
    (updatedAccountInfo, context) =>
12
      console.log("Updated account info: ", updatedAccountInfo),
13
    "confirmed"
14
  );
15
})();
16

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5
from solana.publickey import PublicKey
6

7
async def main():
8
    async with connect("") as websocket:
9
        await websocket.account_subscribe(PublicKey('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk'))
10
        first_resp = await websocket.recv()
11
        subscription_id = first_resp.result
12
        async for idx, msg in enumerate(websocket):
13
            print(msg)
14

15
asyncio.run(main())

1
import solana
2
import asyncio
3
from asyncstdlib import enumerate
4
from solana.rpc.websocket_api import connect
5
from solana.publickey import PublicKey
6

7
async def main():
8
    async with connect("") as websocket:
9
        await websocket.account_subscribe(PublicKey('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk'))
10
        first_resp = await websocket.recv()
11
        subscription_id = first_resp.result
12
        async for idx, msg in enumerate(websocket):
13
            print(msg)
14

15
asyncio.run(main())

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

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

Response

1
{
2
  "jsonrpc": "2.0",
3
  "result": 23784,
4
  "id": 1
5
}

1
{
2
  "jsonrpc": "2.0",
3
  "result": 23784,
4
  "id": 1
5
}

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free