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

쿼리 매개변수

한도

정수

로딩 중...

offset

정수

로딩 중...

반품

데이터

객체

로딩 중...

id

문자열

로딩 중...

created_at

문자열

로딩 중...

updated_at

문자열

로딩 중...

이름

문자열

로딩 중...

네트워크

문자열

로딩 중...

dataset

문자열

로딩 중...

region

문자열

로딩 중...

filter_function

문자열

로딩 중...

start_range

정수

로딩 중...

end_range

정수

로딩 중...

dataset_batch_size

정수

로딩 중...

destination

문자열

로딩 중...

fix_block_reorgs

정수

로딩 중...

keep_distance_from_tip

정수

로딩 중...

destination_attributes

객체

로딩 중...

로딩 중...

url

문자열

로딩 중...

압축

문자열

로딩 중...

헤더

객체

로딩 중...

key-value

문자열

로딩 중...

max_retry

정수

로딩 중...

retry_interval_sec

정수

로딩 중...

post_timeout_sec

정수

로딩 중...

security_token

문자열

로딩 중...

로딩 중...

엔드포인트

문자열

로딩 중...

access_key

문자열

로딩 중...

secret_key

문자열

로딩 중...

bucket

문자열

로딩 중...

object_prefix

문자열

로딩 중...

file_compression_type

문자열

로딩 중...

file_type

문자열

로딩 중...

max_retry

정수

로딩 중...

retry_interval_sec

정수

로딩 중...

use_ssl

부울

로딩 중...

로딩 중...

username

문자열

로딩 중...

비밀번호

문자열

로딩 중...

host

문자열

로딩 중...

port

정수

로딩 중...

sslmode

문자열

로딩 중...

table_name

문자열

로딩 중...

max_retry

정수

로딩 중...

retry_interval_sec

정수

로딩 중...

로딩 중...

username

문자열

로딩 중...

계정

문자열

로딩 중...

warehouse

문자열

로딩 중...

host

문자열

로딩 중...

port

정수

로딩 중...

database

문자열

로딩 중...

protocol

문자열

로딩 중...

schema

문자열

로딩 중...

table_name

문자열

로딩 중...

max_retry

정수

로딩 중...

retry_interval_sec

정수

로딩 중...

상태

문자열

로딩 중...

notification_email

문자열

로딩 중...

순서

정수

로딩 중...

current_hash

문자열

로딩 중...

elastic_batch_enabled

부울

로딩 중...

extra_destinations

배열

로딩 중...

destination

문자열

로딩 중...

destination_attributes

객체

로딩 중...

요청

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 요청
2

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

5
페이로드 = {}
6

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

12
답변 = 요청.요청("GET", url, 헤더=헤더, data=페이로드)
13

14
인쇄(응답.text)
15

1
import 요청
2

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

5
페이로드 = {}
6

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

12
답변 = 요청.요청("GET", url, 헤더=헤더, data=페이로드)
13

14
인쇄(응답.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.호스트, url.포트)
7
https.use_ssl = true
8

9
요청 = 순::HTTP::Get.new(url)
10
요청["수락"] = "application/json"
11
요청["x-api-key"] = "YOUR_API_KEY"
12

13
답변 = https.요청(요청)
14
응답을 넣습니다.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.호스트, url.포트)
7
https.use_ssl = true
8

9
요청 = 순::HTTP::Get.new(url)
10
요청["수락"] = "application/json"
11
요청["x-api-key"] = "YOUR_API_KEY"
12

13
답변 = https.요청(요청)
14
응답을 넣습니다.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
출처: 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
출처: 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
끝
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
끝
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::빌더().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
    알겠습니다(())
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::빌더().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
    알겠습니다(())
19
}
20

Try in Swagger

아직 계정이 없으신가요?

단 몇 초 만에 Quicknode 엔드포인트를 생성하고 개발을 시작하세요

지금 무료로 시작하세요