Retrieve a source
curl --request GET \
--url http://localhost:9601/workspaces/{ws_id}/source/{id}import requests
url = "http://localhost:9601/workspaces/{ws_id}/source/{id}"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('http://localhost:9601/workspaces/{ws_id}/source/{id}', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_PORT => "9601",
CURLOPT_URL => "http://localhost:9601/workspaces/{ws_id}/source/{id}",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "http://localhost:9601/workspaces/{ws_id}/source/{id}"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("http://localhost:9601/workspaces/{ws_id}/source/{id}")
.asString();require 'uri'
require 'net/http'
url = URI("http://localhost:9601/workspaces/{ws_id}/source/{id}")
http = Net::HTTP.new(url.host, url.port)
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_body{
"config": {
"http": {
"methods": [
"POST"
]
}
},
"id": "<string>",
"name": "<string>",
"enabled": true,
"type": "http",
"async": false,
"metadata": {},
"rate_limit": {
"quota": 1,
"period": 2
},
"created_at": 123,
"updated_at": 123
}Source
Retrieve a source
GET
/
workspaces
/
{ws_id}
/
source
/
{id}
Retrieve a source
curl --request GET \
--url http://localhost:9601/workspaces/{ws_id}/source/{id}import requests
url = "http://localhost:9601/workspaces/{ws_id}/source/{id}"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('http://localhost:9601/workspaces/{ws_id}/source/{id}', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_PORT => "9601",
CURLOPT_URL => "http://localhost:9601/workspaces/{ws_id}/source/{id}",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "http://localhost:9601/workspaces/{ws_id}/source/{id}"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("http://localhost:9601/workspaces/{ws_id}/source/{id}")
.asString();require 'uri'
require 'net/http'
url = URI("http://localhost:9601/workspaces/{ws_id}/source/{id}")
http = Net::HTTP.new(url.host, url.port)
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_body{
"config": {
"http": {
"methods": [
"POST"
]
}
},
"id": "<string>",
"name": "<string>",
"enabled": true,
"type": "http",
"async": false,
"metadata": {},
"rate_limit": {
"quota": 1,
"period": 2
},
"created_at": 123,
"updated_at": 123
}Response
200 - application/json
OK
Show child attributes
Show child attributes
Available options:
http Whether to ingest events asynchronously through the queue
Show child attributes
Show child attributes
The rate limit that uses GCRA algorithm (a variant of the leaky bucket algorithm that supports bursts).
Show child attributes
Show child attributes
⌘I