Stream reviews in real-time using Server-Sent Events
curl --request POST \
--url https://py-api.hobbo.ai/{endpoint}-continues/reviews \
--header 'Content-Type: application/json' \
--data '
{
"query": "<string>"
}
'import requests
url = "https://py-api.hobbo.ai/{endpoint}-continues/reviews"
payload = { "query": "<string>" }
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({query: '<string>'})
};
fetch('https://py-api.hobbo.ai/{endpoint}-continues/reviews', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://py-api.hobbo.ai/{endpoint}-continues/reviews",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'query' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://py-api.hobbo.ai/{endpoint}-continues/reviews"
payload := strings.NewReader("{\n \"query\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://py-api.hobbo.ai/{endpoint}-continues/reviews")
.header("Content-Type", "application/json")
.body("{\n \"query\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://py-api.hobbo.ai/{endpoint}-continues/reviews")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"query\": \"<string>\"\n}"
response = http.request(request)
puts response.read_bodydata: {"review_rating": 5, "review_title": "Excellent service!", "review_text": "Great attorney, highly recommended."}}{
"status": 400,
"data": {},
"success": false,
"message": "<string>"
}Scrapper API
Continues description for endpoint
The continuous endpoint streams review data in real-time using Server-Sent Events (SSE). Unlike traditional endpoints that wait for the entire scraping process to complete, this endpoint returns reviews as they are fetched from the source, allowing clients to receive and process data incrementally without waiting for the full response.
POST
/
{endpoint}
-continues
/
reviews
Stream reviews in real-time using Server-Sent Events
curl --request POST \
--url https://py-api.hobbo.ai/{endpoint}-continues/reviews \
--header 'Content-Type: application/json' \
--data '
{
"query": "<string>"
}
'import requests
url = "https://py-api.hobbo.ai/{endpoint}-continues/reviews"
payload = { "query": "<string>" }
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({query: '<string>'})
};
fetch('https://py-api.hobbo.ai/{endpoint}-continues/reviews', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://py-api.hobbo.ai/{endpoint}-continues/reviews",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'query' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://py-api.hobbo.ai/{endpoint}-continues/reviews"
payload := strings.NewReader("{\n \"query\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://py-api.hobbo.ai/{endpoint}-continues/reviews")
.header("Content-Type", "application/json")
.body("{\n \"query\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://py-api.hobbo.ai/{endpoint}-continues/reviews")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"query\": \"<string>\"\n}"
response = http.request(request)
puts response.read_bodydata: {"review_rating": 5, "review_title": "Excellent service!", "review_text": "Great attorney, highly recommended."}}{
"status": 400,
"data": {},
"success": false,
"message": "<string>"
}Path Parameters
The scraper endpoint name (e.g., 'avvo', 'yelp', 'google', 'amazon'). This corresponds to any available review scraper in our system.
Example:
"https://py-api.hobbo.ai/avvo-continues/reviews"
Body
application/json
The URL of the page to scrape reviews from
Response
Reviews streamed successfully via Server-Sent Events. Each event contains review data as it becomes available.
Server-Sent Events stream containing review data chunks