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

Zoekparameters

limiet

geheel getal

Bezig met laden...

offset

geheel getal

Bezig met laden...

Retourzendingen

gegevens

object

Bezig met laden...

id

tekenreeks

Bezig met laden...

created_at

tekenreeks

Bezig met laden...

updated_at

tekenreeks

Bezig met laden...

naam

tekenreeks

Bezig met laden...

netwerk

tekenreeks

Bezig met laden...

dataset

tekenreeks

Bezig met laden...

region

tekenreeks

Bezig met laden...

filter_function

tekenreeks

Bezig met laden...

start_range

geheel getal

Bezig met laden...

end_range

geheel getal

Bezig met laden...

dataset_batch_size

geheel getal

Bezig met laden...

destination

tekenreeks

Bezig met laden...

fix_block_reorgs

geheel getal

Bezig met laden...

keep_distance_from_tip

geheel getal

Bezig met laden...

destination_attributes

object

Bezig met laden...

Bezig met laden...

url

tekenreeks

Bezig met laden...

compression

tekenreeks

Bezig met laden...

headers

object

Bezig met laden...

key-value

tekenreeks

Bezig met laden...

max_retry

geheel getal

Bezig met laden...

retry_interval_sec

geheel getal

Bezig met laden...

post_timeout_sec

geheel getal

Bezig met laden...

security_token

tekenreeks

Bezig met laden...

Bezig met laden...

endpoint

tekenreeks

Bezig met laden...

access_key

tekenreeks

Bezig met laden...

secret_key

tekenreeks

Bezig met laden...

bucket

tekenreeks

Bezig met laden...

object_prefix

tekenreeks

Bezig met laden...

file_compression_type

tekenreeks

Bezig met laden...

file_type

tekenreeks

Bezig met laden...

max_retry

geheel getal

Bezig met laden...

retry_interval_sec

geheel getal

Bezig met laden...

use_ssl

booleaanse waarde

Bezig met laden...

Bezig met laden...

username

tekenreeks

Bezig met laden...

password

tekenreeks

Bezig met laden...

host

tekenreeks

Bezig met laden...

port

geheel getal

Bezig met laden...

sslmode

tekenreeks

Bezig met laden...

table_name

tekenreeks

Bezig met laden...

max_retry

geheel getal

Bezig met laden...

retry_interval_sec

geheel getal

Bezig met laden...

Bezig met laden...

username

tekenreeks

Bezig met laden...

account

tekenreeks

Bezig met laden...

warehouse

tekenreeks

Bezig met laden...

host

tekenreeks

Bezig met laden...

port

geheel getal

Bezig met laden...

database

tekenreeks

Bezig met laden...

protocol

tekenreeks

Bezig met laden...

schema

tekenreeks

Bezig met laden...

table_name

tekenreeks

Bezig met laden...

max_retry

geheel getal

Bezig met laden...

retry_interval_sec

geheel getal

Bezig met laden...

status

tekenreeks

Bezig met laden...

meldings-e-mail

tekenreeks

Bezig met laden...

reeks

geheel getal

Bezig met laden...

current_hash

tekenreeks

Bezig met laden...

elastic_batch_enabled

booleaanse waarde

Bezig met laden...

extra_destinations

array

Bezig met laden...

destination

tekenreeks

Bezig met laden...

destination_attributes

object

Bezig met laden...

Verzoek

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 verzoeken
2

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

5
nuttige lading = {}
6

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

12
antwoord = verzoeken.verzoek("GET", url, headers=headers, gegevens=payload)
13

14
afdrukken(reactie.tekst)
15

1
import verzoeken
2

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

5
nuttige lading = {}
6

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

12
antwoord = verzoeken.verzoek("GET", url, headers=headers, gegevens=payload)
13

14
afdrukken(reactie.tekst)
15

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

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

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

9
verzoek = Netto::HTTP::Get.new(url)
10
verzoek["accepteren"] = "application/json"
11
verzoek["x-api-key"] = "UW_API-SLEUTEL"
12

13
antwoord = https.verzoek(verzoek)
14
geeft het antwoord weer.read_body
15

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

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

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

9
verzoek = Netto::HTTP::Get.new(url)
10
verzoek["accepteren"] = "application/json"
11
verzoek["x-api-key"] = "UW_API-SLEUTEL"
12

13
antwoord = https.verzoek(verzoek)
14
geeft het antwoord weer.read_body
15

1
qn stream list --limit 20 -o json

1
qn stream list --limit 20 -o json

1
import { QuicknodeSdk } van "@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 } van "@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
van 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
van 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
vereist "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
einde
10

1
vereist "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
einde
10

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

3
#[tokio::main]
4
async fn main() -> Result<(), Box<dyn std::error::Error>> {
5
    laat 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
    laat 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

Heb je nog geen account?

Maak binnen enkele seconden je Quicknode-eindpunt aan en ga aan de slag

Ga gratis aan de slag