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.

パラメータ

filters

文字列

読み込み中...

all

文字列

読み込み中...

allWithVotes

文字列

読み込み中...

オブジェクト

オブジェクト

読み込み中...

mentions

配列

読み込み中...

encoding

読み込み中...

オブジェクト

配列

読み込み中...

commitment

文字列

読み込み中...

finalized

文字列

読み込み中...

confirmed

文字列

読み込み中...

processed

文字列

読み込み中...

返品

結果

整数

読み込み中...

Notification Format:

オブジェクト

読み込み中...

署名

文字列

読み込み中...

err

オブジェクト

読み込み中...

logs

配列

読み込み中...

リクエスト

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async 関数 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
メイン();

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

3
const rpcSubscriptions = createSolanaRpcSubscriptions('');
4

5
async 関数 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
メイン();

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"}]}

回答

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

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

まだアカウントをお持ちではありませんか？

Create your Quicknode endpoint in seconds and start building

今すぐ無料で始めましょう