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

Body Parameters

name

string

REQUIRED

network

string

REQUIRED

dataset

string

REQUIRED

filter_function

string

region

string

start_range

integer

end_range

integer

dataset_batch_size

integer

REQUIRED

include_stream_metadata

string

REQUIRED

status

string

REQUIRED

elastic_batch_enabled

boolean

REQUIRED

fix_block_reorgs

integer

keep_distance_from_tip

integer

notification_email

string

destination

string

REQUIRED

destination_attributes

object

url

string

REQUIRED

compression

string

REQUIRED

headers

object

key-value

string

max_retry

integer

REQUIRED

retry_interval_sec

integer

REQUIRED

post_timeout_sec

integer

REQUIRED

destination_attributes

object

endpoint

string

REQUIRED

access_key

string

secret_key

string

REQUIRED

bucket

string

REQUIRED

object_prefix

string

file_compression_type

string

REQUIRED

file_type

string

REQUIRED

max_retry

integer

REQUIRED

retry_interval_sec

integer

REQUIRED

use_ssl

boolean

REQUIRED

destination_attributes

object

storage_account

string

REQUIRED

container

string

REQUIRED

sas_token

string

REQUIRED

blob_prefix

string

file_compression_type

string

REQUIRED

file_type

string

REQUIRED

max_retry

integer

REQUIRED

retry_interval_sec

integer

REQUIRED

destination_attributes

object

username

string

REQUIRED

password

string

REQUIRED

host

string

REQUIRED

port

integer

REQUIRED

sslmode

string

REQUIRED

table_name

string

REQUIRED

max_retry

integer

REQUIRED

retry_interval_sec

integer

REQUIRED

Returns

string

created_at

string

updated_at

string

name

string

network

string

dataset

string

region

string

filter_function

string

start_range

integer

end_range

integer

dataset_batch_size

integer

include_stream_metadata

string

destination

string

fix_block_reorgs

integer

keep_distance_from_tip

integer

destination_attributes

object

url

string

compression

string

headers

object

key-value

string

max_retry

integer

retry_interval_sec

integer

post_timeout_sec

integer

security_token

string

destination_attributes

object

endpoint

string

access_key

string

secret_key

string

bucket

string

object_prefix

string

file_compression_type

string

file_type

string

max_retry

integer

retry_interval_sec

integer

use_ssl

boolean

destination_attributes

object

storage_account

string

container

string

sas_token

string

blob_prefix

string

file_compression_type

string

file_type

string

max_retry

integer

retry_interval_sec

integer

destination_attributes

object

username

string

password

string

host

string

port

integer

sslmode

string

table_name

string

max_retry

integer

retry_interval_sec

integer

status

string

notification_email

string

sequence

integer

current_hash

string

Request

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
  "include_stream_metadata": "body",
16
  "destination": "webhook",
17
  "fix_block_reorgs": 0,
18
  "keep_distance_from_tip": 0,
19
  "elastic_batch_enabled": true,
20
  "destination_attributes": {
21
    "url": "https://wehook.site",
22
    "compression": "none",
23
    "headers": {
24
      "Content-Type": "Test",
25
      "Authorization": "again"
26
    },
27
    "max_retry": 3,
28
    "retry_interval_sec": 1,
29
    "post_timeout_sec": 10
30
  },
31
  "status": "active"
32
}'
33

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
  "include_stream_metadata": "body",
16
  "destination": "webhook",
17
  "fix_block_reorgs": 0,
18
  "keep_distance_from_tip": 0,
19
  "elastic_batch_enabled": true,
20
  "destination_attributes": {
21
    "url": "https://wehook.site",
22
    "compression": "none",
23
    "headers": {
24
      "Content-Type": "Test",
25
      "Authorization": "again"
26
    },
27
    "max_retry": 3,
28
    "retry_interval_sec": 1,
29
    "post_timeout_sec": 10
30
  },
31
  "status": "active"
32
}'
33

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
  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: 'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
15
    region: 'usa_east',
16
    start_range: 100,
17
    end_range: 200,
18
    dataset_batch_size: 1,
19
    include_stream_metadata: 'body',
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
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
  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: 'ZnVuY3Rpb24gbWFpbihkYXRhKSB7CiAgICB2YXIgbnVtYmVyRGVjaW1hbCA9IHBhcnNlSW50KGRhdGEuc3RyZWFtRGF0YS5udW1iZXIsIDE2KTsKICAgIHZhciBmaWx0ZXJlZERhdGEgPSB7CiAgICAgICAgaGFzaDogZGF0YS5zdHJlYW1EYXRhLmhhc2gsCiAgICAgICAgbnVtYmVyOiBudW1iZXJEZWNpbWFsCiAgICB9OwogICAgcmV0dXJuIGZpbHRlcmVkRGF0YTsKfQ==',
15
    region: 'usa_east',
16
    start_range: 100,
17
    end_range: 200,
18
    dataset_batch_size: 1,
19
    include_stream_metadata: 'body',
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
import requests
2

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

5
payload = {
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
    "include_stream_metadata": "body",
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://webhook.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

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

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

41
print(response.text)
42

1
import requests
2

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

5
payload = {
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
    "include_stream_metadata": "body",
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://webhook.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

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

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

41
print(response.text)
42

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")
7

8
https = Net::HTTP.new(url.host, url.port)
9
https.use_ssl = true
10

11
request = Net::HTTP::Post.new(url)
12
request["accept"] = "application/json"
13
request["Content-Type"] = "application/json"
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
  "include_stream_metadata" => "body",
26
  "destination" => "webhook",
27
  "elastic_batch_enabled" => true,
28
  "fix_block_reorgs" => 0,
29
  "keep_distance_from_tip" => 0,
30
  "destination_attributes" => {
31
    "url" => "https://webhook.site",
32
    "compression" => "none",
33
    "headers" => {
34
      "Content-Type" => "Test",
35
      "Authorization" => "again"
36
    },
37
    "max_retry" => 3,
38
    "retry_interval_sec" => 1,
39
    "post_timeout_sec" => 10
40
  },
41
  "status" => "active"
42
}.to_json
43

44
response = https.request(request)
45
puts response.body
46

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")
7

8
https = Net::HTTP.new(url.host, url.port)
9
https.use_ssl = true
10

11
request = Net::HTTP::Post.new(url)
12
request["accept"] = "application/json"
13
request["Content-Type"] = "application/json"
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
  "include_stream_metadata" => "body",
26
  "destination" => "webhook",
27
  "elastic_batch_enabled" => true,
28
  "fix_block_reorgs" => 0,
29
  "keep_distance_from_tip" => 0,
30
  "destination_attributes" => {
31
    "url" => "https://webhook.site",
32
    "compression" => "none",
33
    "headers" => {
34
      "Content-Type" => "Test",
35
      "Authorization" => "again"
36
    },
37
    "max_retry" => 3,
38
    "retry_interval_sec" => 1,
39
    "post_timeout_sec" => 10
40
  },
41
  "status" => "active"
42
}.to_json
43

44
response = https.request(request)
45
puts response.body
46

Try in Swagger

Don't have an account yet?

Create your Quicknode endpoint in seconds and start building

Get started for free

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

Loading...

Body Parameters

Returns