GET /streams/rest/v1/streams REST API Endpoint

Paramètres de requête

limite

entier

Chargement...

décalage

entier

Chargement...

Renvoie

données

objet

Chargement...

ID

chaîne de caractères

Chargement...

created_at

chaîne de caractères

Chargement...

updated_at

chaîne de caractères

Chargement...

nom

chaîne de caractères

Chargement...

réseau

chaîne de caractères

Chargement...

dataset

chaîne de caractères

Chargement...

region

chaîne de caractères

Chargement...

filter_function

chaîne de caractères

Chargement...

start_range

entier

Chargement...

end_range

entier

Chargement...

dataset_batch_size

entier

Chargement...

destination

chaîne de caractères

Chargement...

fix_block_reorgs

entier

Chargement...

keep_distance_from_tip

entier

Chargement...

destination_attributes

objet

Chargement...

Chargement...

url

chaîne de caractères

Chargement...

compression

chaîne de caractères

Chargement...

headers

objet

Chargement...

key-value

chaîne de caractères

Chargement...

max_retry

entier

Chargement...

retry_interval_sec

entier

Chargement...

post_timeout_sec

entier

Chargement...

jeton_de_sécurité

chaîne de caractères

Chargement...

Chargement...

endpoint

chaîne de caractères

Chargement...

access_key

chaîne de caractères

Chargement...

secret_key

chaîne de caractères

Chargement...

bucket

chaîne de caractères

Chargement...

object_prefix

chaîne de caractères

Chargement...

file_compression_type

chaîne de caractères

Chargement...

file_type

chaîne de caractères

Chargement...

max_retry

entier

Chargement...

retry_interval_sec

entier

Chargement...

use_ssl

booléen

Chargement...

Chargement...

username

chaîne de caractères

Chargement...

password

chaîne de caractères

Chargement...

host

chaîne de caractères

Chargement...

port

entier

Chargement...

sslmode

chaîne de caractères

Chargement...

table_name

chaîne de caractères

Chargement...

max_retry

entier

Chargement...

retry_interval_sec

entier

Chargement...

Chargement...

username

chaîne de caractères

Chargement...

compte

chaîne de caractères

Chargement...

warehouse

chaîne de caractères

Chargement...

host

chaîne de caractères

Chargement...

port

entier

Chargement...

database

chaîne de caractères

Chargement...

protocol

chaîne de caractères

Chargement...

schema

chaîne de caractères

Chargement...

table_name

chaîne de caractères

Chargement...

max_retry

entier

Chargement...

retry_interval_sec

entier

Chargement...

statut

chaîne de caractères

Chargement...

e-mail_de_notification

chaîne de caractères

Chargement...

sequence

entier

Chargement...

current_hash

chaîne de caractères

Chargement...

elastic_batch_enabled

booléen

Chargement...

extra_destinations

tableau

Chargement...

destination

chaîne de caractères

Chargement...

destination_attributes

objet

Chargement...

Requête

1
curl -X GET \
2
    "https://api.quicknode.com/streams/rest/v1/streams" \
3
    -H "accept: application/json" \
4
    -H "x-api-key: YOUR_API_KEY"

1
curl -X GET \
2
    "https://api.quicknode.com/streams/rest/v1/streams" \
3
    -H "accept: application/json" \
4
    -H "x-api-key: YOUR_API_KEY"

1
var myHeaders = new Headers()
2
myHeaders.append('accept', 'application/json')
3
myHeaders.append('x-api-key', 'YOUR_API_KEY')
4

5
var requestOptions = {
6
	method: 'GET',
7
	headers: myHeaders,
8
	redirect: 'follow',
9
}
10

11
fetch(
12
	'https://api.quicknode.com/streams/rest/v1/streams',
13
	requestOptions
14
)
15
	.then(response => response.text())
16
	.then(result => console.log(result))
17
	.catch(error => console.log('error', error))
18

1
var myHeaders = new Headers()
2
myHeaders.append('accept', 'application/json')
3
myHeaders.append('x-api-key', 'YOUR_API_KEY')
4

5
var requestOptions = {
6
	method: 'GET',
7
	headers: myHeaders,
8
	redirect: 'follow',
9
}
10

11
fetch(
12
	'https://api.quicknode.com/streams/rest/v1/streams',
13
	requestOptions
14
)
15
	.then(response => response.text())
16
	.then(result => console.log(result))
17
	.catch(error => console.log('error', error))
18

1
import requests
2

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

5
payload = {}
6

7
headers = {
8
    'accept': 'application/json',
9
    'x-api-key': 'YOUR_API_KEY'
10
}
11

12
response = requests.request("GET", url, headers=headers, data=payload)
13

14
print(response.text)
15

1
import requests
2

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

5
payload = {}
6

7
headers = {
8
    'accept': 'application/json',
9
    'x-api-key': 'YOUR_API_KEY'
10
}
11

12
response = requests.request("GET", url, headers=headers, data=payload)
13

14
print(response.text)
15

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

4
url = URI("https://api.quicknode.com/streams/rest/v1/streams")
5

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

9
request = Net::HTTP::Get.new(url)
10
request["accept"] = "application/json"
11
request["x-api-key"] = "YOUR_API_KEY"
12

13
response = https.request(request)
14
puts response.read_body
15

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

4
url = URI("https://api.quicknode.com/streams/rest/v1/streams")
5

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

9
request = Net::HTTP::Get.new(url)
10
request["accept"] = "application/json"
11
request["x-api-key"] = "YOUR_API_KEY"
12

13
response = https.request(request)
14
puts response.read_body
15

1
qn stream list --limit 20 -o json

1
qn stream list --limit 20 -o json

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

3
const qn = new QuicknodeSdk({ apiKey: "YOUR_API_KEY" })
4
const response = await qn.streams.listStreams({ limit: 20, offset: 0 })
5

6
console.log(`Total streams: ${response.pageInfo.total}`)
7
for (const stream of response.data) {
8
	console.log(stream.id, stream.name, stream.status)
9
}
10

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

3
const qn = new QuicknodeSdk({ apiKey: "YOUR_API_KEY" })
4
const response = await qn.streams.listStreams({ limit: 20, offset: 0 })
5

6
console.log(`Total streams: ${response.pageInfo.total}`)
7
for (const stream of response.data) {
8
	console.log(stream.id, stream.name, stream.status)
9
}
10

1
import asyncio
2
from quicknode_sdk import QuicknodeSdk, SdkFullConfig
3

4

5
async def main():
6
    qn = QuicknodeSdk(SdkFullConfig(api_key="YOUR_API_KEY"))
7
    response = await qn.streams.list_streams(limit=20, offset=0)
8

9
    print(f"Total streams: {response.page_info.total}")
10
    for stream in response.data:
11
        print(stream.id, stream.name, stream.status)
12

13

14
asyncio.run(main())
15

1
import asyncio
2
from quicknode_sdk import QuicknodeSdk, SdkFullConfig
3

4

5
async def main():
6
    qn = QuicknodeSdk(SdkFullConfig(api_key="YOUR_API_KEY"))
7
    response = await qn.streams.list_streams(limit=20, offset=0)
8

9
    print(f"Total streams: {response.page_info.total}")
10
    for stream in response.data:
11
        print(stream.id, stream.name, stream.status)
12

13

14
asyncio.run(main())
15

1
require "quicknode_sdk"
2

3
qn = QuicknodeSdk::SDK.from_config(api_key: "YOUR_API_KEY")
4
response = qn.streams.list_streams({ limit: 20, offset: 0 })
5

6
puts "Total streams: #{response["pageInfo"]["total"]}"
7
response["data"].each do |stream|
8
  puts "#{stream["id"]} #{stream["name"]} #{stream["status"]}"
9
end
10

1
require "quicknode_sdk"
2

3
qn = QuicknodeSdk::SDK.from_config(api_key: "YOUR_API_KEY")
4
response = qn.streams.list_streams({ limit: 20, offset: 0 })
5

6
puts "Total streams: #{response["pageInfo"]["total"]}"
7
response["data"].each do |stream|
8
  puts "#{stream["id"]} #{stream["name"]} #{stream["status"]}"
9
end
10

1
use quicknode_sdk::{streams::ListStreamsParams, QuicknodeSdk, SdkFullConfig};
2

3
#[tokio::main]
4
async fn main() -> Result<(), Box<dyn std::error::Error>> {
5
    let qn = QuicknodeSdk::new(&SdkFullConfig::builder().api_key("YOUR_API_KEY").build())?;
6

7
    let params = ListStreamsParams {
8
        limit: Some(20),
9
        offset: Some(0),
10
        ..Default::default()
11
    };
12
    let response = qn.streams.list_streams(&params).await?;
13

14
    println!("Total streams: {}", response.page_info.total);
15
    for stream in response.data {
16
        println!("{} {} {}", stream.id, stream.name, stream.status);
17
    }
18
    Ok(())
19
}
20

1
use quicknode_sdk::{streams::ListStreamsParams, QuicknodeSdk, SdkFullConfig};
2

3
#[tokio::main]
4
async fn main() -> Result<(), Box<dyn std::error::Error>> {
5
    let qn = QuicknodeSdk::new(&SdkFullConfig::builder().api_key("YOUR_API_KEY").build())?;
6

7
    let params = ListStreamsParams {
8
        limit: Some(20),
9
        offset: Some(0),
10
        ..Default::default()
11
    };
12
    let response = qn.streams.list_streams(&params).await?;
13

14
    println!("Total streams: {}", response.page_info.total);
15
    for stream in response.data {
16
        println!("{} {} {}", stream.id, stream.name, stream.status);
17
    }
18
    Ok(())
19
}
20

Try in Swagger

Vous n'avez pas encore de compte ?

Créez votre endpoint Quicknode en quelques secondes et commencez à développer

Commencez gratuitement