/streams/rest/v1/streams/test_filter REST API Endpoint

身体参数

网络

字符串

必填

正在加载...

dataset

字符串

必填

正在加载...

filter_function

string<base64>

必填

正在加载...

块

字符串

必填

正在加载...

退货

结果

字符串

正在加载...

请求

1
curl -X POST \
2
    "https://api.quicknode.com/streams/rest/v1/streams/test_filter" \
3
    -H "accept: application/json" \
4
    -H "Content-Type: application/json" \
5
    -H "x-api-key: YOUR_API_KEY" \
6
    -d $'{
7
  "network": "ethereum-mainnet",
8
  "dataset": "block",
9
  "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
10
  "block": "17811625"
11
}'
12
    

1
curl -X POST \
2
    "https://api.quicknode.com/streams/rest/v1/streams/test_filter" \
3
    -H "accept: application/json" \
4
    -H "Content-Type: application/json" \
5
    -H "x-api-key: YOUR_API_KEY" \
6
    -d $'{
7
  "network": "ethereum-mainnet",
8
  "dataset": "block",
9
  "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
10
  "block": "17811625"
11
}'
12
    

1
var myHeaders = new Headers();
2
myHeaders.append('accept', 'application/json');
3
myHeaders.append('Content-Type', 'application/json');
4
myHeaders.append('x-api-key', 'YOUR_API_KEY'); // Replace with your actual API key
5

6
var requestOptions = {
7
  方法: 'POST',
8
  标题: myHeaders,
9
  redirect: 'follow',
10
  body: JSON.stringify({
11
    network: 'ethereum-mainnet',
12
    dataset: 'block',
13
    filter_function: 'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
14
    block: '17811625'
15
  })
16
};
17

18
fetch('https://api.quicknode.com/streams/rest/v1/streams/test_filter', requestOptions)
19
  .然后(响应 => 响应.text())
20
  .然后(结果 => 控制台.log(result))
21
  .catch(error => 控制台.log('error', error));
22

1
var myHeaders = new Headers();
2
myHeaders.append('accept', 'application/json');
3
myHeaders.append('Content-Type', 'application/json');
4
myHeaders.append('x-api-key', 'YOUR_API_KEY'); // Replace with your actual API key
5

6
var requestOptions = {
7
  方法: 'POST',
8
  标题: myHeaders,
9
  redirect: 'follow',
10
  body: JSON.stringify({
11
    network: 'ethereum-mainnet',
12
    dataset: 'block',
13
    filter_function: 'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
14
    block: '17811625'
15
  })
16
};
17

18
fetch('https://api.quicknode.com/streams/rest/v1/streams/test_filter', requestOptions)
19
  .然后(响应 => 响应.text())
20
  .然后(结果 => 控制台.log(result))
21
  .catch(error => 控制台.log('error', error));
22

1
导入 请求
2

3
url = "https://api.quicknode.com/streams/rest/v1/streams/test_filter"
4

5
有效载荷 = {
6
    "network": "ethereum-mainnet",
7
    "dataset": "block",
8
    "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
9
    "block": "17811625"
10
}
11

12
标题 = {
13
    "accept": "application/json",
14
    "Content-Type": "application/json",
15
    "x-api-key": "YOUR_API_KEY"  # Replace with your actual API key
16
}
17

18
response = requests.post(url, headers=headers, json=payload)
19

20
打印(响应.text)
21

1
导入 请求
2

3
url = "https://api.quicknode.com/streams/rest/v1/streams/test_filter"
4

5
有效载荷 = {
6
    "network": "ethereum-mainnet",
7
    "dataset": "block",
8
    "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
9
    "block": "17811625"
10
}
11

12
标题 = {
13
    "accept": "application/json",
14
    "Content-Type": "application/json",
15
    "x-api-key": "YOUR_API_KEY"  # Replace with your actual API key
16
}
17

18
response = requests.post(url, headers=headers, json=payload)
19

20
打印(响应.text)
21

1
require "uri"
2
require "net/http"
3
require "json"
4

5
# Set up the URL for the request
6
url = URI("https://api.quicknode.com/streams/rest/v1/streams/test_filter")
7

8
https = Net::HTTP.new(url.主机, url.端口)
9
https.use_ssl = true
10

11
请求 = Net::HTTP::POST.new(url)
12
请求["接受"] = "application/json"
13
请求["Content-Type"] = "application/json"
14
request["x-api-key"] = "YOUR_API_KEY"  # Replace with your actual API key
15

16
request.body = {
17
  "network" => "ethereum-mainnet",
18
  "dataset" => "block",
19
  "filter_function" => "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
20
  "block" => "17811625"
21
}.to_json
22

23
回复 = https.请求(请求)
24
返回响应.正文
25

1
require "uri"
2
require "net/http"
3
require "json"
4

5
# Set up the URL for the request
6
url = URI("https://api.quicknode.com/streams/rest/v1/streams/test_filter")
7

8
https = Net::HTTP.new(url.主机, url.端口)
9
https.use_ssl = true
10

11
请求 = Net::HTTP::POST.new(url)
12
请求["接受"] = "application/json"
13
请求["Content-Type"] = "application/json"
14
request["x-api-key"] = "YOUR_API_KEY"  # Replace with your actual API key
15

16
request.body = {
17
  "network" => "ethereum-mainnet",
18
  "dataset" => "block",
19
  "filter_function" => "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
20
  "block" => "17811625"
21
}.to_json
22

23
回复 = https.请求(请求)
24
返回响应.正文
25

1
qn stream test-filter --network ethereum-mainnet \
2
      --dataset block \
3
      --block 18000000 \
4
      --filter-file ./filter.js \
5
      --filter-language javascript \
6
      -o json

1
qn stream test-filter --network ethereum-mainnet \
2
      --dataset block \
3
      --block 18000000 \
4
      --filter-file ./filter.js \
5
      --filter-language javascript \
6
      -o json

1
import { QuicknodeSdk, StreamDataset } from "@quicknode/sdk"
2

3
const qn = new QuicknodeSdk({ apiKey: "YOUR_API_KEY" })
4

5
const filterFunction = Buffer.from(`
6
function main(data) {
7
	return data
8
}
9
`).toString("base64")
10

11
const result = await qn.streams.testFilter({
12
	network: "ethereum-mainnet",
13
	dataset: StreamDataset.Block,
14
	block: "17811625",
15
	filterFunction,
16
})
17

18
console.log("logs:", result.logs)
19
console.log("result:", result.result)
20

1
import { QuicknodeSdk, StreamDataset } from "@quicknode/sdk"
2

3
const qn = new QuicknodeSdk({ apiKey: "YOUR_API_KEY" })
4

5
const filterFunction = Buffer.from(`
6
function main(data) {
7
	return data
8
}
9
`).toString("base64")
10

11
const result = await qn.streams.testFilter({
12
	network: "ethereum-mainnet",
13
	dataset: StreamDataset.Block,
14
	block: "17811625",
15
	filterFunction,
16
})
17

18
console.log("logs:", result.logs)
19
console.log("result:", result.result)
20

1
import asyncio
2
import base64
3
来源 quicknode_sdk import QuicknodeSdk, SdkFullConfig
4

5

6
async def main():
7
    qn = QuicknodeSdk(SdkFullConfig(api_key="您的API密钥"))
8

9
    filter_function = base64.b64encode(
10
        b"function main(data) { return data; }"
11
    ).decode()
12

13
    result = await qn.streams.test_filter(
14
        network="ethereum-mainnet",
15
        dataset="block",
16
        block="17811625",
17
        filter_function=filter_function,
18
    )
19

20
    print("logs:", result.logs)
21
    print("result:", result.result)
22

23

24
asyncio.run(main()))
25

1
import asyncio
2
import base64
3
来源 quicknode_sdk import QuicknodeSdk, SdkFullConfig
4

5

6
async def main():
7
    qn = QuicknodeSdk(SdkFullConfig(api_key="您的API密钥"))
8

9
    filter_function = base64.b64encode(
10
        b"function main(data) { return data; }"
11
    ).decode()
12

13
    result = await qn.streams.test_filter(
14
        network="ethereum-mainnet",
15
        dataset="block",
16
        block="17811625",
17
        filter_function=filter_function,
18
    )
19

20
    print("logs:", result.logs)
21
    print("result:", result.result)
22

23

24
asyncio.run(main()))
25

1
require "base64"
2
require "quicknode_sdk"
3

4
qn = QuicknodeSdk::SDK.from_config(api_key: "YOUR_API_KEY")
5

6
filter_function = Base64.strict_encode64("function main(data) { return data; }")
7

8
result = qn.streams.test_filter(
9
  network: "ethereum-mainnet",
10
  dataset: "block",
11
  block: "17811625",
12
  filter_function: filter_function,
13
)
14

15
puts "logs: #{result["logs"]}"
16
puts "result: #{result["result"]}"
17

1
require "base64"
2
require "quicknode_sdk"
3

4
qn = QuicknodeSdk::SDK.from_config(api_key: "YOUR_API_KEY")
5

6
filter_function = Base64.strict_encode64("function main(data) { return data; }")
7

8
result = qn.streams.test_filter(
9
  network: "ethereum-mainnet",
10
  dataset: "block",
11
  block: "17811625",
12
  filter_function: filter_function,
13
)
14

15
puts "logs: #{result["logs"]}"
16
puts "result: #{result["result"]}"
17

1
use quicknode_sdk::{
2
    streams::{StreamDataset, TestFilterParams},
3
    QuicknodeSdk,
4
    SdkFullConfig,
5
};
6

7
#[tokio::main]
8
async fn main() -> Result<(), Box<dyn std::error::Error>> {
9
    let qn = QuicknodeSdk::new(&SdkFullConfig::builder().api_key("您的API密钥").build())?;
10

11
    // Base64-encoded: function main(data) { return data; }
12
    let filter_function = "ZnVuY3Rpb24gbWFpbihkYXRhKSB7IHJldHVybiBkYXRhOyB9".to_string();
13

14
    let params = TestFilterParams {
15
        network: "ethereum-mainnet".to_string(),
16
        dataset: StreamDataset::Block,
17
        block: "17811625".to_string(),
18
        filter_function: Some(filter_function),
19
        filter_language: None,
20
        address_book_config: None,
21
    };
22
    let result = qn.streams.test_filter(&params).await?;
23

24
    println!("logs: {:?}", result.logs);
25
    println!("result: {}", result.result);
26
    好的(())
27
}
28

1
use quicknode_sdk::{
2
    streams::{StreamDataset, TestFilterParams},
3
    QuicknodeSdk,
4
    SdkFullConfig,
5
};
6

7
#[tokio::main]
8
async fn main() -> Result<(), Box<dyn std::error::Error>> {
9
    let qn = QuicknodeSdk::new(&SdkFullConfig::builder().api_key("您的API密钥").build())?;
10

11
    // Base64-encoded: function main(data) { return data; }
12
    let filter_function = "ZnVuY3Rpb24gbWFpbihkYXRhKSB7IHJldHVybiBkYXRhOyB9".to_string();
13

14
    let params = TestFilterParams {
15
        network: "ethereum-mainnet".to_string(),
16
        dataset: StreamDataset::Block,
17
        block: "17811625".to_string(),
18
        filter_function: Some(filter_function),
19
        filter_language: None,
20
        address_book_config: None,
21
    };
22
    let result = qn.streams.test_filter(&params).await?;
23

24
    println!("logs: {:?}", result.logs);
25
    println!("result: {}", result.result);
26
    好的(())
27
}
28

Try in Swagger

还没有账号吗？

只需几秒钟即可创建您的 Quicknode 端点，并开始构建

免费开始使用