Overview
Activates a paused stream to resume data ingestion and delivery to your configured destination. Use this endpoint to restart a stream that was previously paused.
Key behaviors:
- Stream resumes from where it was paused
- Data delivery continues to the configured destination
- No configuration changes are made
- Stream status changes from
pausedtoactive
Endpoint
Send a POST request to activate a paused stream.
POST https://api.quicknode.com/streams/rest/v1/streams/{id}/activate
Path Parameters
| Parameter | Type | Required | Description |
|---|---|---|---|
| id | string | Yes | The unique identifier (UUID) of the stream to activate |
Example Request
- cURL
- CLI
- JavaScript
Python
- Ruby
- SDK (JS)
SDK (Python)
- SDK (Ruby)
- SDK (Rust)
curl -X POST "https://api.quicknode.com/streams/rest/v1/streams/f6ad6459-b5ad-4183-b370-1c1388e47e83/activate" \
-H "accept: application/json" \
-H "x-api-key: YOUR_API_KEY"
qn stream activate f6ad6459-b5ad-4183-b370-1c1388e47e83 -o json
const headers = new Headers()
headers.append('accept', 'application/json')
headers.append('x-api-key', 'YOUR_API_KEY')
fetch('https://api.quicknode.com/streams/rest/v1/streams/f6ad6459-b5ad-4183-b370-1c1388e47e83/activate', {
method: 'POST',
headers: headers
})
.then(response => response.json())
.then(data => console.log(data))
.catch(error => console.error('Error:', error))
import requests
url = "https://api.quicknode.com/streams/rest/v1/streams/f6ad6459-b5ad-4183-b370-1c1388e47e83/activate"
headers = {
"accept": "application/json",
"x-api-key": "YOUR_API_KEY"
}
response = requests.post(url, headers=headers)
print(response.json())
require "uri"
require "net/http"
url = URI("https://api.quicknode.com/streams/rest/v1/streams/f6ad6459-b5ad-4183-b370-1c1388e47e83/activate")
https = Net::HTTP.new(url.host, url.port)
https.use_ssl = true
request = Net::HTTP::Post.new(url)
request["accept"] = "application/json"
request["x-api-key"] = "YOUR_API_KEY"
response = https.request(request)
puts response.body
import { QuicknodeSdk } from "@quicknode/sdk"
const qn = new QuicknodeSdk({ apiKey: "YOUR_API_KEY" })
await qn.streams.activateStream("f6ad6459-b5ad-4183-b370-1c1388e47e83")
console.log("Stream activated")
import asyncio
from quicknode_sdk import QuicknodeSdk, SdkFullConfig
async def main():
qn = QuicknodeSdk(SdkFullConfig(api_key="YOUR_API_KEY"))
await qn.streams.activate_stream("f6ad6459-b5ad-4183-b370-1c1388e47e83")
print("Stream activated")
asyncio.run(main())
require "quicknode_sdk"
qn = QuicknodeSdk::SDK.from_config(api_key: "YOUR_API_KEY")
qn.streams.activate_stream(id: "f6ad6459-b5ad-4183-b370-1c1388e47e83")
puts "Stream activated"
use quicknode_sdk::{QuicknodeSdk, SdkFullConfig};
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let qn = QuicknodeSdk::new(&SdkFullConfig::builder().api_key("YOUR_API_KEY").build())?;
qn.streams.activate_stream("f6ad6459-b5ad-4183-b370-1c1388e47e83").await?;
println!("Stream activated");
Ok(())
}
Response
On success, the API returns a confirmation message.
{
"code": 200,
"msg": "Stream activated successfully",
"data": null
}
Response Fields
| Field | Type | Description |
|---|---|---|
| code | number | HTTP status code (200 for success) |
| msg | string | Confirmation message |
| data | null | No additional data returned |