accountSubscribe RPC Method

Parameters

Pubkey

string

Loading...

object

object

Loading...

commitment

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