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.

Parameter

filters

Zeichenkette

Wird geladen...

all

Zeichenkette

Wird geladen...

allWithVotes

Zeichenkette

Wird geladen...

Objekt

Objekt

Wird geladen...

mentions

Array

Wird geladen...

encoding

Wird geladen...

Objekt

Array

Wird geladen...

commitment

Zeichenkette

Wird geladen...

finalized

Zeichenkette

Wird geladen...

confirmed

Zeichenkette

Wird geladen...

processed

Zeichenkette

Wird geladen...

Rücksendungen

Ergebnis

Ganzzahl

Wird geladen...

Notification Format:

Objekt

Wird geladen...

Unterschrift

Zeichenkette

Wird geladen...

ähm

Objekt

Wird geladen...

Protokolle

Array

Wird geladen...

Anfrage

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async Funktion 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
Hauptseite();

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async Funktion 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
Hauptseite();

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
# Auf Verbindung warten 
3
{"jsonrpc": "2.0", "id": 1, "method": "logsSubscribe", "params": [{"mentions": ["E645TckHQnDcavVv92Etc6xSWQaq8zzPtPRGBheviRAk"]}, {"commitment": "finalized"}]}

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

Antwort

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

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

Hast du noch kein Konto?

Erstellen Sie Ihrenendpoint Sekundenschnelle und legen Sie los

Kostenlos loslegen