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

cadena

Cargando...

all

cadena

Cargando...

allWithVotes

cadena

Cargando...

objeto

objeto

Cargando...

mentions

matriz

Cargando...

encoding

Cargando...

objeto

matriz

Cargando...

commitment

cadena

Cargando...

finalized

cadena

Cargando...

confirmed

cadena

Cargando...

processed

cadena

Cargando...

Devoluciones

resultado

entero

Cargando...

Notification Format:

objeto

Cargando...

firma

cadena

Cargando...

err

objeto

Cargando...

registros

matriz

Cargando...

Solicitud

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
asíncrono función 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
asíncrono función 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
# 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"}]}

Respuesta

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

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

¿Aún no tienes una cuenta?

Crea tu punto de conexión de Quicknode en cuestión de segundos y empieza a desarrollar

Empieza gratis