POST /streams/rest/v1/streams REST API Endpoint

शरीर के मापदंड

नाम

डोरी

आवश्यक

लोड हो रहा है...

नेटवर्क

डोरी

आवश्यक

लोड हो रहा है...

dataset

डोरी

आवश्यक

लोड हो रहा है...

filter_function

डोरी

लोड हो रहा है...

region

डोरी

आवश्यक

लोड हो रहा है...

usa_east

start_range

पूर्णांक

लोड हो रहा है...

end_range

पूर्णांक

लोड हो रहा है...

dataset_batch_size

पूर्णांक

आवश्यक

लोड हो रहा है...

स्थिति

डोरी

आवश्यक

लोड हो रहा है...

activepaused

elastic_batch_enabled

बूलियन

आवश्यक

लोड हो रहा है...

fix_block_reorgs

पूर्णांक

लोड हो रहा है...

keep_distance_from_tip

पूर्णांक

लोड हो रहा है...

notification_email

डोरी

लोड हो रहा है...

destination

डोरी

आवश्यक

लोड हो रहा है...

WEbhooks3azurepostgres

destination_attributes

वस्तु

आवश्यक

लोड हो रहा है...

url

डोरी

आवश्यक

लोड हो रहा है...

compression

डोरी

आवश्यक

लोड हो रहा है...

nonegzip

हेडर

वस्तु

लोड हो रहा है...

key-value

डोरी

लोड हो रहा है...

max_retry

पूर्णांक

आवश्यक

लोड हो रहा है...

retry_interval_sec

पूर्णांक

आवश्यक

लोड हो रहा है...

post_timeout_sec

पूर्णांक

आवश्यक

लोड हो रहा है...

extra_destinations

सरणी

लोड हो रहा है...

destination

डोरी

आवश्यक

लोड हो रहा है...

WEbhooks3azurepostgres

destination_attributes

वस्तु

आवश्यक

लोड हो रहा है...

रिटर्न

पहचान

डोरी

लोड हो रहा है...

बनाया गया_पर

डोरी

लोड हो रहा है...

updated_at

डोरी

लोड हो रहा है...

नाम

डोरी

लोड हो रहा है...

नेटवर्क

डोरी

लोड हो रहा है...

dataset

डोरी

लोड हो रहा है...

region

डोरी

लोड हो रहा है...

filter_function

डोरी

लोड हो रहा है...

start_range

पूर्णांक

लोड हो रहा है...

end_range

पूर्णांक

लोड हो रहा है...

dataset_batch_size

पूर्णांक

लोड हो रहा है...

destination

डोरी

लोड हो रहा है...

fix_block_reorgs

पूर्णांक

लोड हो रहा है...

keep_distance_from_tip

पूर्णांक

लोड हो रहा है...

destination_attributes

वस्तु

लोड हो रहा है...

url

डोरी

लोड हो रहा है...

compression

डोरी

लोड हो रहा है...

हेडर

वस्तु

लोड हो रहा है...

key-value

डोरी

लोड हो रहा है...

max_retry

पूर्णांक

लोड हो रहा है...

retry_interval_sec

पूर्णांक

लोड हो रहा है...

post_timeout_sec

पूर्णांक

लोड हो रहा है...

security_token

डोरी

लोड हो रहा है...

स्थिति

डोरी

लोड हो रहा है...

notification_email

डोरी

लोड हो रहा है...

sequence

पूर्णांक

लोड हो रहा है...

current_hash

डोरी

लोड हो रहा है...

elastic_batch_enabled

बूलियन

लोड हो रहा है...

extra_destinations

सरणी

लोड हो रहा है...

destination

डोरी

लोड हो रहा है...

destination_attributes

वस्तु

लोड हो रहा है...

अनुरोध

1
curl -X POST \
2
    "https://api.quicknode.com/streams/rest/v1/streams" \
3
    -H "accept: application/json" \
4
    -H "Content-Type: application/json" \
5
    -H "x-api-key: YOUR_API_KEY" \
6
    -d $'{
7
  "name": "My Stream",
8
  "network": "ethereum-mainnet",
9
  "dataset": "block",
10
  "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
11
  "region": "usa_east",
12
  "start_range": 100,
13
  "end_range": 200,
14
  "dataset_batch_size": 1,
15
  "destination": "webhook",
16
  "fix_block_reorgs": 0,
17
  "keep_distance_from_tip": 0,
18
  "elastic_batch_enabled": true,
19
  "destination_attributes": {
20
    "url": "https://wehook.site",
21
    "compression": "none",
22
    "headers": {
23
      "Content-Type": "Test",
24
      "Authorization": "again"
25
    },
26
    "max_retry": 3,
27
    "retry_interval_sec": 1,
28
    "post_timeout_sec": 10
29
  },
30
  "status": "active"
31
}'
32

1
curl -X POST \
2
    "https://api.quicknode.com/streams/rest/v1/streams" \
3
    -H "accept: application/json" \
4
    -H "Content-Type: application/json" \
5
    -H "x-api-key: YOUR_API_KEY" \
6
    -d $'{
7
  "name": "My Stream",
8
  "network": "ethereum-mainnet",
9
  "dataset": "block",
10
  "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
11
  "region": "usa_east",
12
  "start_range": 100,
13
  "end_range": 200,
14
  "dataset_batch_size": 1,
15
  "destination": "webhook",
16
  "fix_block_reorgs": 0,
17
  "keep_distance_from_tip": 0,
18
  "elastic_batch_enabled": true,
19
  "destination_attributes": {
20
    "url": "https://wehook.site",
21
    "compression": "none",
22
    "headers": {
23
      "Content-Type": "Test",
24
      "Authorization": "again"
25
    },
26
    "max_retry": 3,
27
    "retry_interval_sec": 1,
28
    "post_timeout_sec": 10
29
  },
30
  "status": "active"
31
}'
32

1
const 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
const requestOptions = {
7
	method: 'POST',
8
	headers: myHeaders,
9
	redirect: 'follow',
10
	body: JSON.stringify({
11
		name: 'My Stream',
12
		network: 'ethereum-mainnet',
13
		dataset: 'block',
14
		filter_function:
15
			'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
16
		region: 'usa_east',
17
		start_range: 100,
18
		end_range: 200,
19
		dataset_batch_size: 1,
20
		destination: 'webhook',
21
		elastic_batch_enabled: true,
22
		fix_block_reorgs: 0,
23
		keep_distance_from_tip: 0,
24
		destination_attributes: {
25
			url: 'https://webhook.site',
26
			compression: 'none',
27
			headers: {
28
				'Content-Type': 'Test',
29
				Authorization: 'again',
30
			},
31
			max_retry: 3,
32
			retry_interval_sec: 1,
33
			post_timeout_sec: 10,
34
		},
35
		status: 'active',
36
	}),
37
}
38

39
fetch('https://api.quicknode.com/streams/rest/v1/streams', requestOptions)
40
	.then(response => response.text())
41
	.then(result => console.log(result))
42
	.catch(error => console.log('error', error))
43

1
const 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
const requestOptions = {
7
	method: 'POST',
8
	headers: myHeaders,
9
	redirect: 'follow',
10
	body: JSON.stringify({
11
		name: 'My Stream',
12
		network: 'ethereum-mainnet',
13
		dataset: 'block',
14
		filter_function:
15
			'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
16
		region: 'usa_east',
17
		start_range: 100,
18
		end_range: 200,
19
		dataset_batch_size: 1,
20
		destination: 'webhook',
21
		elastic_batch_enabled: true,
22
		fix_block_reorgs: 0,
23
		keep_distance_from_tip: 0,
24
		destination_attributes: {
25
			url: 'https://webhook.site',
26
			compression: 'none',
27
			headers: {
28
				'Content-Type': 'Test',
29
				Authorization: 'again',
30
			},
31
			max_retry: 3,
32
			retry_interval_sec: 1,
33
			post_timeout_sec: 10,
34
		},
35
		status: 'active',
36
	}),
37
}
38

39
fetch('https://api.quicknode.com/streams/rest/v1/streams', requestOptions)
40
	.then(response => response.text())
41
	.then(result => console.log(result))
42
	.catch(error => console.log('error', error))
43

1
आयात अनुरोध
2

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

5
पेलोड = {
6
    "name": "My Stream",
7
    "network": "ethereum-mainnet",
8
    "dataset": "block",
9
    "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
10
    "region": "usa_east",
11
    "start_range": 100,
12
    "end_range": 200,
13
    "dataset_batch_size": 1,
14
    "destination": "webhook",
15
    "fix_block_reorgs": 0,
16
    "keep_distance_from_tip": 0,
17
    "elastic_batch_enabled": True,
18
    "destination_attributes": {
19
        "url": "https://webhook.site",
20
        "compression": "none",
21
        "headers": {
22
            "Content-Type": "Test",
23
            "Authorization": "again"
24
        },
25
        "max_retry": 3,
26
        "retry_interval_sec": 1,
27
        "post_timeout_sec": 10
28
    } ,
29
    "status": "active"
30
}
31

32
हेडर = {
33
    "accept": "application/json",
34
    "Content-Type": "application/json",
35
    "x-api-key": "YOUR_API_KEY"  # Replace with your actual API key
36
}
37

38
response = requests.post(url, headers=headers, json=payload)
39

40
प्रिंट ( प्रतिक्रिया . पाठ )
41

1
आयात अनुरोध
2

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

5
पेलोड = {
6
    "name": "My Stream",
7
    "network": "ethereum-mainnet",
8
    "dataset": "block",
9
    "filter_function": "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
10
    "region": "usa_east",
11
    "start_range": 100,
12
    "end_range": 200,
13
    "dataset_batch_size": 1,
14
    "destination": "webhook",
15
    "fix_block_reorgs": 0,
16
    "keep_distance_from_tip": 0,
17
    "elastic_batch_enabled": True,
18
    "destination_attributes": {
19
        "url": "https://webhook.site",
20
        "compression": "none",
21
        "headers": {
22
            "Content-Type": "Test",
23
            "Authorization": "again"
24
        },
25
        "max_retry": 3,
26
        "retry_interval_sec": 1,
27
        "post_timeout_sec": 10
28
    } ,
29
    "status": "active"
30
}
31

32
हेडर = {
33
    "accept": "application/json",
34
    "Content-Type": "application/json",
35
    "x-api-key": "YOUR_API_KEY"  # Replace with your actual API key
36
}
37

38
response = requests.post(url, headers=headers, json=payload)
39

40
प्रिंट ( प्रतिक्रिया . पाठ )
41

1
ज़रूरत होना "उरी"
2
ज़रूरत होना "नेट/http"
3
ज़रूरत होना "जेसन"
4

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

8
https = Net :: HTTP . new ( url . host , url . port )
9
https . use_ssl = सत्य
10

11
अनुरोध = नेट :: एचटीटीपी :: पोस्ट.नया ( यूआरएल )
12
अनुरोध [ "स्वीकार करें" ] = "एप्लिकेशन/जेसन"
13
अनुरोध [ "सामग्री-प्रकार" ] = "एप्लिकेशन/जेसन"
14
request["x-api-key"] = "YOUR_API_KEY"  # Replace with your actual API key
15

16
request.body = {
17
  "name" => "My Stream",
18
  "network" => "ethereum-mainnet",
19
  "dataset" => "block",
20
  "filter_function" => "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
21
  "region" => "usa_east",
22
  "start_range" => 100,
23
  "end_range" => 200,
24
  "dataset_batch_size" => 1,
25
  "destination" => "webhook",
26
  "elastic_batch_enabled" => true,
27
  "fix_block_reorgs" => 0,
28
  "keep_distance_from_tip" => 0,
29
  "destination_attributes" => {
30
    "url" => "https://webhook.site",
31
    "compression" => "none",
32
    "headers" => {
33
      "Content-Type" => "Test",
34
      "Authorization" => "again"
35
    } ,
36
    "max_retry" => 3,
37
    "retry_interval_sec" => 1,
38
    "post_timeout_sec" => 10
39
  } ,
40
  "status" => "active"
41
}.to_json
42

43
प्रतिक्रिया = https . अनुरोध ( अनुरोध )
44
प्रतिक्रिया देता है . शरीर
45

1
ज़रूरत होना "उरी"
2
ज़रूरत होना "नेट/http"
3
ज़रूरत होना "जेसन"
4

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

8
https = Net :: HTTP . new ( url . host , url . port )
9
https . use_ssl = सत्य
10

11
अनुरोध = नेट :: एचटीटीपी :: पोस्ट.नया ( यूआरएल )
12
अनुरोध [ "स्वीकार करें" ] = "एप्लिकेशन/जेसन"
13
अनुरोध [ "सामग्री-प्रकार" ] = "एप्लिकेशन/जेसन"
14
request["x-api-key"] = "YOUR_API_KEY"  # Replace with your actual API key
15

16
request.body = {
17
  "name" => "My Stream",
18
  "network" => "ethereum-mainnet",
19
  "dataset" => "block",
20
  "filter_function" => "ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==",
21
  "region" => "usa_east",
22
  "start_range" => 100,
23
  "end_range" => 200,
24
  "dataset_batch_size" => 1,
25
  "destination" => "webhook",
26
  "elastic_batch_enabled" => true,
27
  "fix_block_reorgs" => 0,
28
  "keep_distance_from_tip" => 0,
29
  "destination_attributes" => {
30
    "url" => "https://webhook.site",
31
    "compression" => "none",
32
    "headers" => {
33
      "Content-Type" => "Test",
34
      "Authorization" => "again"
35
    } ,
36
    "max_retry" => 3,
37
    "retry_interval_sec" => 1,
38
    "post_timeout_sec" => 10
39
  } ,
40
  "status" => "active"
41
}.to_json
42

43
प्रतिक्रिया = https . अनुरोध ( अनुरोध )
44
प्रतिक्रिया देता है . शरीर
45

1
asyncio आयात करें
2
import base64
3
from quicknode_sdk import QuicknodeSdk, SdkFullConfig, StreamWebhookDestination, WebhookAttributes
4

5

6
अतुल्यकालिक डीईएफ़ मुख्य ( ) :
7
qn = QuicknodeSdk ( SdkFullConfig ( api_key = "YOUR_API_KEY" ) )
8

9
    filter_function = base64.b64encode(b"""
10
function main(data) {
11
    return {
12
        hash: data.streamData.hash,
13
        number: parseInt(data.streamData.number, 16)
14
    };
15
}
16
""").decode()
17

18
    stream = await qn.streams.create_stream(
19
        name="My Stream",
20
        network="ethereum-mainnet",
21
        dataset="block",
22
        region="usa_east",
23
        start_range=100,
24
        end_range=200,
25
        dataset_batch_size=1,
26
        elastic_batch_enabled=True,
27
        fix_block_reorgs=0,
28
        keep_distance_from_tip=0,
29
        filter_function=filter_function,
30
        status="active",
31
        plan="growth_plan",
32
        threshold_fetch_buffer=1000,
33
        destination_attributes=StreamWebhookDestination(
34
            WebhookAttributes(
35
                url="https://webhook.site",
36
                max_retry=3,
37
                retry_interval_sec=1,
38
                post_timeout_sec=10,
39
                compression="none",
40
            )
41
        ),
42
    )
43

44
    print(stream.id, stream.status)
45

46

47
asyncio.run ( main ( ) )
48

1
asyncio आयात करें
2
import base64
3
from quicknode_sdk import QuicknodeSdk, SdkFullConfig, StreamWebhookDestination, WebhookAttributes
4

5

6
अतुल्यकालिक डीईएफ़ मुख्य ( ) :
7
qn = QuicknodeSdk ( SdkFullConfig ( api_key = "YOUR_API_KEY" ) )
8

9
    filter_function = base64.b64encode(b"""
10
function main(data) {
11
    return {
12
        hash: data.streamData.hash,
13
        number: parseInt(data.streamData.number, 16)
14
    };
15
}
16
""").decode()
17

18
    stream = await qn.streams.create_stream(
19
        name="My Stream",
20
        network="ethereum-mainnet",
21
        dataset="block",
22
        region="usa_east",
23
        start_range=100,
24
        end_range=200,
25
        dataset_batch_size=1,
26
        elastic_batch_enabled=True,
27
        fix_block_reorgs=0,
28
        keep_distance_from_tip=0,
29
        filter_function=filter_function,
30
        status="active",
31
        plan="growth_plan",
32
        threshold_fetch_buffer=1000,
33
        destination_attributes=StreamWebhookDestination(
34
            WebhookAttributes(
35
                url="https://webhook.site",
36
                max_retry=3,
37
                retry_interval_sec=1,
38
                post_timeout_sec=10,
39
                compression="none",
40
            )
41
        ),
42
    )
43

44
    print(stream.id, stream.status)
45

46

47
asyncio.run ( main ( ) )
48

1
use quicknode_sdk::{
2
    streams::{
3
        CreateStreamParams, DestinationAttributes, StreamDataset, StreamRegion, StreamStatus,
4
        WebhookAttributes,
5
    } ,
6
    QuicknodeSdk,
7
    SdkFullConfig,
8
} ;
9

10
#[टोकियो::मुख्य]
11
async fn main() -> Result<(), Box<dyn std::error::Error>> {
12
    मान लीजिए qn = QuicknodeSdk :: new ( & SdkFullConfig :: builder ( ) . api_key ( "YOUR_API_KEY" ) . build ( ) ) ? ;
13

14
    // Base64-encoded:
15
    //   function main(data) { return { hash: data.streamData.hash, number: parseInt(data.streamData.number, 16) }; }
16
    let filter_function = "ZnVuY3Rpb24gbWFpbihkYXRhKSB7IHJldHVybiB7IGhhc2g6IGRhdGEuc3RyZWFtRGF0YS5oYXNoLCBudW1iZXI6IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KSB9OyB9".to_string();
17

18
    let params = CreateStreamParams::builder()
19
        .name("My Stream".to_string())
20
        .network("ethereum-mainnet".to_string())
21
        .dataset(StreamDataset::Block)
22
        .region(StreamRegion::UsaEast)
23
        .start_range(100)
24
        .end_range(200)
25
        .dataset_batch_size(1)
26
        .elastic_batch_enabled(true)
27
        .fix_block_reorgs(0)
28
        .keep_distance_from_tip(0)
29
        .filter_function(filter_function)
30
        .status(StreamStatus::Active)
31
        .plan("growth_plan".to_string())
32
        .threshold_fetch_buffer(1000)
33
        .destination_attributes(DestinationAttributes::Webhook(WebhookAttributes {
34
            url: "https://webhook.site".to_string(),
35
            compression: "none".to_string(),
36
            max_retry: 3,
37
            retry_interval_sec: 1,
38
            post_timeout_sec: 10,
39
            security_token: None,
40
        }))
41
        .build();
42

43
    let stream = qn.streams.create_stream(&params).await?;
44

45
    println!("{} {}", stream.id, stream.status);
46
    ठीक है ( ( ) )
47
}
48

1
use quicknode_sdk::{
2
    streams::{
3
        CreateStreamParams, DestinationAttributes, StreamDataset, StreamRegion, StreamStatus,
4
        WebhookAttributes,
5
    } ,
6
    QuicknodeSdk,
7
    SdkFullConfig,
8
} ;
9

10
#[टोकियो::मुख्य]
11
async fn main() -> Result<(), Box<dyn std::error::Error>> {
12
    मान लीजिए qn = QuicknodeSdk :: new ( & SdkFullConfig :: builder ( ) . api_key ( "YOUR_API_KEY" ) . build ( ) ) ? ;
13

14
    // Base64-encoded:
15
    //   function main(data) { return { hash: data.streamData.hash, number: parseInt(data.streamData.number, 16) }; }
16
    let filter_function = "ZnVuY3Rpb24gbWFpbihkYXRhKSB7IHJldHVybiB7IGhhc2g6IGRhdGEuc3RyZWFtRGF0YS5oYXNoLCBudW1iZXI6IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KSB9OyB9".to_string();
17

18
    let params = CreateStreamParams::builder()
19
        .name("My Stream".to_string())
20
        .network("ethereum-mainnet".to_string())
21
        .dataset(StreamDataset::Block)
22
        .region(StreamRegion::UsaEast)
23
        .start_range(100)
24
        .end_range(200)
25
        .dataset_batch_size(1)
26
        .elastic_batch_enabled(true)
27
        .fix_block_reorgs(0)
28
        .keep_distance_from_tip(0)
29
        .filter_function(filter_function)
30
        .status(StreamStatus::Active)
31
        .plan("growth_plan".to_string())
32
        .threshold_fetch_buffer(1000)
33
        .destination_attributes(DestinationAttributes::Webhook(WebhookAttributes {
34
            url: "https://webhook.site".to_string(),
35
            compression: "none".to_string(),
36
            max_retry: 3,
37
            retry_interval_sec: 1,
38
            post_timeout_sec: 10,
39
            security_token: None,
40
        }))
41
        .build();
42

43
    let stream = qn.streams.create_stream(&params).await?;
44

45
    println!("{} {}", stream.id, stream.status);
46
    ठीक है ( ( ) )
47
}
48

Try in Swagger

अब तक कोई खाता नहीं है?

कुछ ही सेकंड में अपना क्विकनोड एंडपॉइंट बनाएं और निर्माण शुरू करें।

मुफ़्त में शुरुआत करें