curl --request POST \
--url https://scraping-api.55-tech.com/amqp \
--header 'Content-Type: application/json' \
--header 'X-API-Key: <api-key>' \
--data '
{
"apiKey": "<string>",
"host": "<string>",
"port": 5672,
"virtual_host": "/",
"username": "",
"password": "",
"exchange": "",
"routing_key": "#",
"queue_prefix": "scrape",
"ssl": false,
"heartbeat": 60,
"geo": "<string>",
"agent": "<string>"
}
'import requests
url = "https://scraping-api.55-tech.com/amqp"
payload = {
"apiKey": "<string>",
"host": "<string>",
"port": 5672,
"virtual_host": "/",
"username": "",
"password": "",
"exchange": "",
"routing_key": "#",
"queue_prefix": "scrape",
"ssl": False,
"heartbeat": 60,
"geo": "<string>",
"agent": "<string>"
}
headers = {
"X-API-Key": "<api-key>",
"Content-Type": "application/json"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'X-API-Key': '<api-key>', 'Content-Type': 'application/json'},
body: JSON.stringify({
apiKey: '<string>',
host: '<string>',
port: 5672,
virtual_host: '/',
username: '',
password: '',
exchange: '',
routing_key: '#',
queue_prefix: 'scrape',
ssl: false,
heartbeat: 60,
geo: '<string>',
agent: '<string>'
})
};
fetch('https://scraping-api.55-tech.com/amqp', 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://scraping-api.55-tech.com/amqp",
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([
'apiKey' => '<string>',
'host' => '<string>',
'port' => 5672,
'virtual_host' => '/',
'username' => '',
'password' => '',
'exchange' => '',
'routing_key' => '#',
'queue_prefix' => 'scrape',
'ssl' => false,
'heartbeat' => 60,
'geo' => '<string>',
'agent' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json",
"X-API-Key: <api-key>"
],
]);
$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://scraping-api.55-tech.com/amqp"
payload := strings.NewReader("{\n \"apiKey\": \"<string>\",\n \"host\": \"<string>\",\n \"port\": 5672,\n \"virtual_host\": \"/\",\n \"username\": \"\",\n \"password\": \"\",\n \"exchange\": \"\",\n \"routing_key\": \"#\",\n \"queue_prefix\": \"scrape\",\n \"ssl\": false,\n \"heartbeat\": 60,\n \"geo\": \"<string>\",\n \"agent\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("X-API-Key", "<api-key>")
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://scraping-api.55-tech.com/amqp")
.header("X-API-Key", "<api-key>")
.header("Content-Type", "application/json")
.body("{\n \"apiKey\": \"<string>\",\n \"host\": \"<string>\",\n \"port\": 5672,\n \"virtual_host\": \"/\",\n \"username\": \"\",\n \"password\": \"\",\n \"exchange\": \"\",\n \"routing_key\": \"#\",\n \"queue_prefix\": \"scrape\",\n \"ssl\": false,\n \"heartbeat\": 60,\n \"geo\": \"<string>\",\n \"agent\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://scraping-api.55-tech.com/amqp")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["X-API-Key"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"apiKey\": \"<string>\",\n \"host\": \"<string>\",\n \"port\": 5672,\n \"virtual_host\": \"/\",\n \"username\": \"\",\n \"password\": \"\",\n \"exchange\": \"\",\n \"routing_key\": \"#\",\n \"queue_prefix\": \"scrape\",\n \"ssl\": false,\n \"heartbeat\": 60,\n \"geo\": \"<string>\",\n \"agent\": \"<string>\"\n}"
response = http.request(request)
puts response.read_body"<string>"AMQP consumer relay (SSE)
Connect to an AMQP/RabbitMQ broker through an agent and stream messages as Server-Sent Events. The agent creates a temporary auto-delete queue, binds it to the specified exchange, and streams messages back as SSE events (connected, message, error).
curl --request POST \
--url https://scraping-api.55-tech.com/amqp \
--header 'Content-Type: application/json' \
--header 'X-API-Key: <api-key>' \
--data '
{
"apiKey": "<string>",
"host": "<string>",
"port": 5672,
"virtual_host": "/",
"username": "",
"password": "",
"exchange": "",
"routing_key": "#",
"queue_prefix": "scrape",
"ssl": false,
"heartbeat": 60,
"geo": "<string>",
"agent": "<string>"
}
'import requests
url = "https://scraping-api.55-tech.com/amqp"
payload = {
"apiKey": "<string>",
"host": "<string>",
"port": 5672,
"virtual_host": "/",
"username": "",
"password": "",
"exchange": "",
"routing_key": "#",
"queue_prefix": "scrape",
"ssl": False,
"heartbeat": 60,
"geo": "<string>",
"agent": "<string>"
}
headers = {
"X-API-Key": "<api-key>",
"Content-Type": "application/json"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'X-API-Key': '<api-key>', 'Content-Type': 'application/json'},
body: JSON.stringify({
apiKey: '<string>',
host: '<string>',
port: 5672,
virtual_host: '/',
username: '',
password: '',
exchange: '',
routing_key: '#',
queue_prefix: 'scrape',
ssl: false,
heartbeat: 60,
geo: '<string>',
agent: '<string>'
})
};
fetch('https://scraping-api.55-tech.com/amqp', 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://scraping-api.55-tech.com/amqp",
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([
'apiKey' => '<string>',
'host' => '<string>',
'port' => 5672,
'virtual_host' => '/',
'username' => '',
'password' => '',
'exchange' => '',
'routing_key' => '#',
'queue_prefix' => 'scrape',
'ssl' => false,
'heartbeat' => 60,
'geo' => '<string>',
'agent' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json",
"X-API-Key: <api-key>"
],
]);
$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://scraping-api.55-tech.com/amqp"
payload := strings.NewReader("{\n \"apiKey\": \"<string>\",\n \"host\": \"<string>\",\n \"port\": 5672,\n \"virtual_host\": \"/\",\n \"username\": \"\",\n \"password\": \"\",\n \"exchange\": \"\",\n \"routing_key\": \"#\",\n \"queue_prefix\": \"scrape\",\n \"ssl\": false,\n \"heartbeat\": 60,\n \"geo\": \"<string>\",\n \"agent\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("X-API-Key", "<api-key>")
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://scraping-api.55-tech.com/amqp")
.header("X-API-Key", "<api-key>")
.header("Content-Type", "application/json")
.body("{\n \"apiKey\": \"<string>\",\n \"host\": \"<string>\",\n \"port\": 5672,\n \"virtual_host\": \"/\",\n \"username\": \"\",\n \"password\": \"\",\n \"exchange\": \"\",\n \"routing_key\": \"#\",\n \"queue_prefix\": \"scrape\",\n \"ssl\": false,\n \"heartbeat\": 60,\n \"geo\": \"<string>\",\n \"agent\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://scraping-api.55-tech.com/amqp")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["X-API-Key"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"apiKey\": \"<string>\",\n \"host\": \"<string>\",\n \"port\": 5672,\n \"virtual_host\": \"/\",\n \"username\": \"\",\n \"password\": \"\",\n \"exchange\": \"\",\n \"routing_key\": \"#\",\n \"queue_prefix\": \"scrape\",\n \"ssl\": false,\n \"heartbeat\": 60,\n \"geo\": \"<string>\",\n \"agent\": \"<string>\"\n}"
response = http.request(request)
puts response.read_body"<string>"Authorizations
API key passed in the X-API-Key header.
Body
API key for authentication.
AMQP broker hostname.
Broker port. Use 5671 for SSL.
AMQP virtual host.
AMQP username.
AMQP password.
Exchange to bind to.
Routing key pattern (# = all messages).
Prefix for the auto-delete queue name.
Use AMQPS (TLS) connection.
AMQP heartbeat interval in seconds.
Country filter for agent selection (e.g. DE).
Pin to specific agent by slug (e.g. de1).
Response
SSE stream of AMQP messages. Events: connected, message, error.
The response is of type string.