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.

Parâmetros

filters

cadeia de caracteres

A carregar...

all

cadeia de caracteres

A carregar...

allWithVotes

cadeia de caracteres

A carregar...

objeto

objeto

A carregar...

mentions

matriz

A carregar...

encoding

A carregar...

objeto

matriz

A carregar...

commitment

cadeia de caracteres

A carregar...

finalized

cadeia de caracteres

A carregar...

confirmed

cadeia de caracteres

A carregar...

processed

cadeia de caracteres

A carregar...

Devoluções

resultado

número inteiro

A carregar...

Notification Format:

objeto

A carregar...

assinatura

cadeia de caracteres

A carregar...

err

objeto

A carregar...

registos

matriz

A carregar...

Pedido

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async função 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
principal();

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async função 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
principal();

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

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.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
# aguardar a ligação 
3
{"jsonrpc": "2.0", "id": 1, "method": "logsSubscribe", "params": [{"mentions": ["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"]}, {"commitment": "finalized"}]}

1
wscat -c  \ 
2
# aguardar a ligação 
3
{"jsonrpc": "2.0", "id": 1, "method": "logsSubscribe", "params": [{"mentions": ["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"]}, {"commitment": "finalized"}]}

Resposta

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

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

Ainda não tem uma conta?

Crie o seu ponto de extremidade Quicknode em segundos e comece a desenvolver

Comece gratuitamente