logsSubscribe 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

filters

tekenreeks

Bezig met laden...

alle

tekenreeks

Bezig met laden...

allWithVotes

tekenreeks

Bezig met laden...

object

object

Bezig met laden...

mentions

array

Bezig met laden...

encoding

Bezig met laden...

object

array

Bezig met laden...

toewijding

tekenreeks

Bezig met laden...

afgerond

tekenreeks

Bezig met laden...

bevestigd

tekenreeks

Bezig met laden...

verwerkt

tekenreeks

Bezig met laden...

Retourzendingen

resultaat

geheel getal

Bezig met laden...

Notification Format:

object

Bezig met laden...

handtekening

tekenreeks

Bezig met laden...

eh

object

Bezig met laden...

logs

array

Bezig met laden...

Verzoek

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async functie main() {
6
    const publicKeyString = address('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk');
7
    const abortController = new AbortController();
8

9
    const subscription = await rpcSubscriptions
10
        .logsNotifications({ mentions: [publicKeyString] })
11
        .subscribe(
12
            { abortSignal: abortController.signal }
13
        );
14

15
        try {
16
            for await (const notification of subscription) {
17
                console.log("Updated account info: ", notification);
18
            }
19
        } catch (e) {
20
            console.error("Error in logs subscription:", e);
21
        } finally {
22
            abortController.abort();
23
            console.log('Unsubscribed from logs');
24
        }
25
}
26

27
hoofdpagina();

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async functie main() {
6
    const publicKeyString = address('E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk');
7
    const abortController = new AbortController();
8

9
    const subscription = await rpcSubscriptions
10
        .logsNotifications({ mentions: [publicKeyString] })
11
        .subscribe(
12
            { abortSignal: abortController.signal }
13
        );
14

15
        try {
16
            for await (const notification of subscription) {
17
                console.log("Updated account info: ", notification);
18
            }
19
        } catch (e) {
20
            console.error("Error in logs subscription:", e);
21
        } finally {
22
            abortController.abort();
23
            console.log('Unsubscribed from logs');
24
        }
25
}
26

27
hoofdpagina();

1
const web3 = require("solana.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.onLogs(
10
    publicKey,
11
    (logs, context) => console.log("Updated account info: ", logs),
12
    "confirmed"
13
  );
14
})();
15

1
const web3 = require("solana.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.onLogs(
10
    publicKey,
11
    (logs, context) => console.log("Updated account info: ", logs),
12
    "confirmed"
13
  );
14
})();
15

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

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

14
asyncio.run(main())

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

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

14
asyncio.run(main())

1
wscat -c  \ 
2
# wait for connection 
3
{"jsonrpc": "2.0", "id": 1, "method": "logsSubscribe", "params": [{"mentions": ["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"]}, {"commitment": "finalized"}]}

1
wscat -c  \ 
2
# wait for connection 
3
{"jsonrpc": "2.0", "id": 1, "method": "logsSubscribe", "params": [{"mentions": ["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"]}, {"commitment": "finalized"}]}

Antwoord

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

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

Heb je nog geen account?

Maakendpoint enkele seconden jeendpoint aan en ga aan de slag

Ga gratis aan de slag