curl --request GET \
--url https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages \
--header 'Authorization: Bearer <token>'import requests
url = "https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages"
headers = {"Authorization": "Bearer <token>"}
response = requests.get(url, headers=headers)
print(response.text)const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};
fetch('https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages', 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://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>"
],
]);
$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 := "https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("Authorization", "Bearer <token>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages")
.header("Authorization", "Bearer <token>")
.asString();require 'uri'
require 'net/http'
url = URI("https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'
response = http.request(request)
puts response.read_body{
"messages": [
{
"id": "019400aa-bbbb-7ccc-8ddd-eeeeffff0000",
"crn": "crn:queue:sa-saopaulo-1:acme:queue/orders/message/019400aa-bbbb-7ccc-8ddd-eeeeffff0000",
"queue_id": "a1b2c3d4-5e6f-4a7b-8c9d-0e1f2a3b4c5d",
"visibility": "available",
"receive_count": 0,
"enqueued_at": "2026-01-18T11:45:00Z",
"visible_at": "2026-01-18T11:45:00Z",
"expires_at": "2026-01-22T11:45:00Z",
"body": "{\"order_id\":\"A-1001\"}",
"attributes": {
"severity": {
"type": "String",
"value": "critical"
},
"attempt": {
"type": "Number",
"value": "2"
}
},
"body_bytes": 24,
"message_group_id": "customer-42",
"first_received_at": "2026-01-18T11:46:10Z"
}
],
"meta": {
"total": 150,
"limit": 20,
"marker": "550e8400-e29b-41d4-a716-446655440000",
"has_more": true
}
}{
"error": {
"code": "UNAUTHORIZED",
"message": "Authentication required",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}{
"error": {
"code": "ACCESS_DENIED",
"message": "You don't have permission to perform this action",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}{
"error": {
"code": "NOT_FOUND",
"message": "Resource not found",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}Inspeccionar mensajes de una cola
Lee sin conceder mensajes: no incrementa receive_count, no oculta mensajes a los consumidores y no devuelve recibos. Requiere queue:PeekMessages para permitir la inspección sin autorizar el consumo de la cola.
curl --request GET \
--url https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages \
--header 'Authorization: Bearer <token>'import requests
url = "https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages"
headers = {"Authorization": "Bearer <token>"}
response = requests.get(url, headers=headers)
print(response.text)const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};
fetch('https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages', 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://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>"
],
]);
$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 := "https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("Authorization", "Bearer <token>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages")
.header("Authorization", "Bearer <token>")
.asString();require 'uri'
require 'net/http'
url = URI("https://queue.{region}.basaltic.sh/v1/queues/{queue_id}/messages")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'
response = http.request(request)
puts response.read_body{
"messages": [
{
"id": "019400aa-bbbb-7ccc-8ddd-eeeeffff0000",
"crn": "crn:queue:sa-saopaulo-1:acme:queue/orders/message/019400aa-bbbb-7ccc-8ddd-eeeeffff0000",
"queue_id": "a1b2c3d4-5e6f-4a7b-8c9d-0e1f2a3b4c5d",
"visibility": "available",
"receive_count": 0,
"enqueued_at": "2026-01-18T11:45:00Z",
"visible_at": "2026-01-18T11:45:00Z",
"expires_at": "2026-01-22T11:45:00Z",
"body": "{\"order_id\":\"A-1001\"}",
"attributes": {
"severity": {
"type": "String",
"value": "critical"
},
"attempt": {
"type": "Number",
"value": "2"
}
},
"body_bytes": 24,
"message_group_id": "customer-42",
"first_received_at": "2026-01-18T11:46:10Z"
}
],
"meta": {
"total": 150,
"limit": 20,
"marker": "550e8400-e29b-41d4-a716-446655440000",
"has_more": true
}
}{
"error": {
"code": "UNAUTHORIZED",
"message": "Authentication required",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}{
"error": {
"code": "ACCESS_DENIED",
"message": "You don't have permission to perform this action",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}{
"error": {
"code": "NOT_FOUND",
"message": "Resource not found",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}queue:PeekMessages. Consulte QUEUE permisos para la lista completa, el alcance de cada acción y un ejemplo de política.Autorizaciones
Un token bearer de OAuth 2.0, enviado como Authorization: Bearer <token>. Esta es la forma recomendada de autenticación.
Obtén el token intercambiando el par de claves de acceso de una cuenta de servicio en POST /v1/oauth/token con grant_type=client_credentials. Es el flujo estándar de credenciales de cliente; las bibliotecas compatibles con OAuth pueden obtener y renovar el token por ti.
curl -s -u "$KEY_ID:$SECRET" -d grant_type=client_credentials \
https://iam.basaltic.sh/v1/oauth/token
Los tokens duran una hora por defecto. El mismo par de claves de acceso también sirve como credencial AWS SigV4 para el endpoint de objetos compatible con S3, que solo acepta ese método de autenticación.
Parámetros de ruta
"a1b2c3d4-5e6f-4a7b-8c9d-0e1f2a3b4c5d"
Parámetros de consulta
CRN exacto del mensaje en esta cola. Los CRN de otro ámbito devuelven una página vacía antes de paginar; los CRN malformados devuelven 400.
"crn:queue:sa-saopaulo-1:acme:queue/orders/message/019400aa-bbbb-7ccc-8ddd-eeeeffff0000"
Restringe la inspección: available puede recibirse ahora; in_flight está concedido; delayed aún no se ha entregado y su retraso no ha terminado.
available, in_flight, delayed "available"
ID del último elemento de la página anterior.
"a1b2c3d4-5e6f-4a7b-8c9d-0e1f2a3b4c5d"
Número máximo de artículos a devolver. Un valor mayor se sujeta al máximo en lugar de ser rechazado, por lo que page until meta.has_more es false.
1 <= x <= 20050

