Crear una cola
curl --request POST \
--url https://queue.{region}.basaltic.sh/v1/queues \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"name": "orders",
"visibility_timeout_seconds": 30,
"message_retention_seconds": 345600,
"max_message_bytes": 262144,
"delay_seconds": 0,
"receive_wait_time_seconds": 0,
"kms_data_key_reuse_period_seconds": 300,
"content_based_deduplication": false,
"kms_key": "crn:kms:sa-saopaulo-1:acme:key/service-key",
"tags": {
"environment": "production",
"team": "backend"
}
}
'import requests
url = "https://queue.{region}.basaltic.sh/v1/queues"
payload = {
"name": "orders",
"visibility_timeout_seconds": 30,
"message_retention_seconds": 345600,
"max_message_bytes": 262144,
"delay_seconds": 0,
"receive_wait_time_seconds": 0,
"kms_data_key_reuse_period_seconds": 300,
"content_based_deduplication": False,
"kms_key": "crn:kms:sa-saopaulo-1:acme:key/service-key",
"tags": {
"environment": "production",
"team": "backend"
}
}
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({
name: 'orders',
visibility_timeout_seconds: 30,
message_retention_seconds: 345600,
max_message_bytes: 262144,
delay_seconds: 0,
receive_wait_time_seconds: 0,
kms_data_key_reuse_period_seconds: 300,
content_based_deduplication: false,
kms_key: 'crn:kms:sa-saopaulo-1:acme:key/service-key',
tags: {environment: 'production', team: 'backend'}
})
};
fetch('https://queue.{region}.basaltic.sh/v1/queues', 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",
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([
'name' => 'orders',
'visibility_timeout_seconds' => 30,
'message_retention_seconds' => 345600,
'max_message_bytes' => 262144,
'delay_seconds' => 0,
'receive_wait_time_seconds' => 0,
'kms_data_key_reuse_period_seconds' => 300,
'content_based_deduplication' => false,
'kms_key' => 'crn:kms:sa-saopaulo-1:acme:key/service-key',
'tags' => [
'environment' => 'production',
'team' => 'backend'
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"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://queue.{region}.basaltic.sh/v1/queues"
payload := strings.NewReader("{\n \"name\": \"orders\",\n \"visibility_timeout_seconds\": 30,\n \"message_retention_seconds\": 345600,\n \"max_message_bytes\": 262144,\n \"delay_seconds\": 0,\n \"receive_wait_time_seconds\": 0,\n \"kms_data_key_reuse_period_seconds\": 300,\n \"content_based_deduplication\": false,\n \"kms_key\": \"crn:kms:sa-saopaulo-1:acme:key/service-key\",\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
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://queue.{region}.basaltic.sh/v1/queues")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"name\": \"orders\",\n \"visibility_timeout_seconds\": 30,\n \"message_retention_seconds\": 345600,\n \"max_message_bytes\": 262144,\n \"delay_seconds\": 0,\n \"receive_wait_time_seconds\": 0,\n \"kms_data_key_reuse_period_seconds\": 300,\n \"content_based_deduplication\": false,\n \"kms_key\": \"crn:kms:sa-saopaulo-1:acme:key/service-key\",\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://queue.{region}.basaltic.sh/v1/queues")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"name\": \"orders\",\n \"visibility_timeout_seconds\": 30,\n \"message_retention_seconds\": 345600,\n \"max_message_bytes\": 262144,\n \"delay_seconds\": 0,\n \"receive_wait_time_seconds\": 0,\n \"kms_data_key_reuse_period_seconds\": 300,\n \"content_based_deduplication\": false,\n \"kms_key\": \"crn:kms:sa-saopaulo-1:acme:key/service-key\",\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}"
response = http.request(request)
puts response.read_body{
"queue": {
"id": "a1b2c3d4-5e6f-4a7b-8c9d-0e1f2a3b4c5d",
"crn": "crn:queue:sa-saopaulo-1:my-account:queue/orders",
"name": "orders",
"kind": "standard",
"attributes": {
"visibility_timeout_seconds": 30,
"message_retention_seconds": 345600,
"max_message_bytes": 262144,
"delay_seconds": 0,
"receive_wait_time_seconds": 0,
"kms_data_key_reuse_period_seconds": 300
},
"created_at": "2026-01-15T09:30:00Z",
"updated_at": "2026-01-18T11:45:00Z",
"redrive_policy": {
"dead_letter_queue": {
"id": "b2c3d4e5-6f7a-4b8c-9d0e-1f2a3b4c5d6e",
"crn": "crn:queue:sa-saopaulo-1:acme:queue/failed-orders",
"name": "failed-orders"
},
"max_receive_count": 5
},
"content_based_deduplication": false,
"kms_key": {
"id": "c3d4e5f6-7a8b-4c9d-8e0f-1a2b3c4d5e6f",
"crn": "crn:kms:sa-saopaulo-1:acme:key/service-key",
"name": "service-key"
},
"tags": {
"environment": "production",
"team": "backend"
},
"depth": {
"approximate_available": 42,
"approximate_in_flight": 3,
"approximate_delayed": 0,
"counts_capped": false
}
}
}{
"error": {
"code": "INVALID_INPUT",
"message": "Invalid request parameters",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}{
"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"
}
}{
"error": {
"code": "INVALID_INPUT",
"message": "Invalid request parameters",
"request_id": "550e8400-e29b-41d4-a716-446655440000",
"params": {
"instances": 2,
"pools": 0
}
}
}{
"error": {
"code": "IDEMPOTENCY_KEY_REUSED",
"message": "This Idempotency-Key was already used with a different request payload",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}Colas
Crear una cola
El tipo procede del nombre: .fifo crea FIFO; cualquier otro nombre crea una cola estándar. No hay un indicador separado que pueda diferir.
POST
/
v1
/
queues
Crear una cola
curl --request POST \
--url https://queue.{region}.basaltic.sh/v1/queues \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"name": "orders",
"visibility_timeout_seconds": 30,
"message_retention_seconds": 345600,
"max_message_bytes": 262144,
"delay_seconds": 0,
"receive_wait_time_seconds": 0,
"kms_data_key_reuse_period_seconds": 300,
"content_based_deduplication": false,
"kms_key": "crn:kms:sa-saopaulo-1:acme:key/service-key",
"tags": {
"environment": "production",
"team": "backend"
}
}
'import requests
url = "https://queue.{region}.basaltic.sh/v1/queues"
payload = {
"name": "orders",
"visibility_timeout_seconds": 30,
"message_retention_seconds": 345600,
"max_message_bytes": 262144,
"delay_seconds": 0,
"receive_wait_time_seconds": 0,
"kms_data_key_reuse_period_seconds": 300,
"content_based_deduplication": False,
"kms_key": "crn:kms:sa-saopaulo-1:acme:key/service-key",
"tags": {
"environment": "production",
"team": "backend"
}
}
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({
name: 'orders',
visibility_timeout_seconds: 30,
message_retention_seconds: 345600,
max_message_bytes: 262144,
delay_seconds: 0,
receive_wait_time_seconds: 0,
kms_data_key_reuse_period_seconds: 300,
content_based_deduplication: false,
kms_key: 'crn:kms:sa-saopaulo-1:acme:key/service-key',
tags: {environment: 'production', team: 'backend'}
})
};
fetch('https://queue.{region}.basaltic.sh/v1/queues', 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",
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([
'name' => 'orders',
'visibility_timeout_seconds' => 30,
'message_retention_seconds' => 345600,
'max_message_bytes' => 262144,
'delay_seconds' => 0,
'receive_wait_time_seconds' => 0,
'kms_data_key_reuse_period_seconds' => 300,
'content_based_deduplication' => false,
'kms_key' => 'crn:kms:sa-saopaulo-1:acme:key/service-key',
'tags' => [
'environment' => 'production',
'team' => 'backend'
]
]),
CURLOPT_HTTPHEADER => [
"Authorization: Bearer <token>",
"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://queue.{region}.basaltic.sh/v1/queues"
payload := strings.NewReader("{\n \"name\": \"orders\",\n \"visibility_timeout_seconds\": 30,\n \"message_retention_seconds\": 345600,\n \"max_message_bytes\": 262144,\n \"delay_seconds\": 0,\n \"receive_wait_time_seconds\": 0,\n \"kms_data_key_reuse_period_seconds\": 300,\n \"content_based_deduplication\": false,\n \"kms_key\": \"crn:kms:sa-saopaulo-1:acme:key/service-key\",\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "Bearer <token>")
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://queue.{region}.basaltic.sh/v1/queues")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"name\": \"orders\",\n \"visibility_timeout_seconds\": 30,\n \"message_retention_seconds\": 345600,\n \"max_message_bytes\": 262144,\n \"delay_seconds\": 0,\n \"receive_wait_time_seconds\": 0,\n \"kms_data_key_reuse_period_seconds\": 300,\n \"content_based_deduplication\": false,\n \"kms_key\": \"crn:kms:sa-saopaulo-1:acme:key/service-key\",\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://queue.{region}.basaltic.sh/v1/queues")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"name\": \"orders\",\n \"visibility_timeout_seconds\": 30,\n \"message_retention_seconds\": 345600,\n \"max_message_bytes\": 262144,\n \"delay_seconds\": 0,\n \"receive_wait_time_seconds\": 0,\n \"kms_data_key_reuse_period_seconds\": 300,\n \"content_based_deduplication\": false,\n \"kms_key\": \"crn:kms:sa-saopaulo-1:acme:key/service-key\",\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}"
response = http.request(request)
puts response.read_body{
"queue": {
"id": "a1b2c3d4-5e6f-4a7b-8c9d-0e1f2a3b4c5d",
"crn": "crn:queue:sa-saopaulo-1:my-account:queue/orders",
"name": "orders",
"kind": "standard",
"attributes": {
"visibility_timeout_seconds": 30,
"message_retention_seconds": 345600,
"max_message_bytes": 262144,
"delay_seconds": 0,
"receive_wait_time_seconds": 0,
"kms_data_key_reuse_period_seconds": 300
},
"created_at": "2026-01-15T09:30:00Z",
"updated_at": "2026-01-18T11:45:00Z",
"redrive_policy": {
"dead_letter_queue": {
"id": "b2c3d4e5-6f7a-4b8c-9d0e-1f2a3b4c5d6e",
"crn": "crn:queue:sa-saopaulo-1:acme:queue/failed-orders",
"name": "failed-orders"
},
"max_receive_count": 5
},
"content_based_deduplication": false,
"kms_key": {
"id": "c3d4e5f6-7a8b-4c9d-8e0f-1a2b3c4d5e6f",
"crn": "crn:kms:sa-saopaulo-1:acme:key/service-key",
"name": "service-key"
},
"tags": {
"environment": "production",
"team": "backend"
},
"depth": {
"approximate_available": 42,
"approximate_in_flight": 3,
"approximate_delayed": 0,
"counts_capped": false
}
}
}{
"error": {
"code": "INVALID_INPUT",
"message": "Invalid request parameters",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}{
"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"
}
}{
"error": {
"code": "INVALID_INPUT",
"message": "Invalid request parameters",
"request_id": "550e8400-e29b-41d4-a716-446655440000",
"params": {
"instances": 2,
"pools": 0
}
}
}{
"error": {
"code": "IDEMPOTENCY_KEY_REUSED",
"message": "This Idempotency-Key was already used with a different request payload",
"request_id": "550e8400-e29b-41d4-a716-446655440000"
}
}Requiere la acción IAM
queue:CreateQueue. 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.
Encabezados
Clave opcional generada por el cliente que hace que una creación sea segura para la reproducción. Al volver a intentar una solicitud con la misma clave, se devuelve el resultado original literalmente en lugar de crear un recurso duplicado. Se rechaza la reutilización de una clave con un cuerpo de solicitud diferente (422); una solicitud cuya clave todavía se está procesando devuelve 409. Los registros se mantienen durante 24 horas. Usa un UUID o un token único similar.
Maximum string length:
255Cuerpo
application/json
Letras, dígitos, punto, guion o guion bajo, empezando por letra o dígito. El sufijo .fifo crea una cola FIFO. Los nombres no pueden empezar por crn: ni ser UUID en formato canónico, compacto, entre llaves o urn:uuid:, sin distinguir mayúsculas.
Maximum string length:
80Ejemplo:
"orders"
Rango requerido:
0 <= x <= 43200Ejemplo:
30
Rango requerido:
60 <= x <= 1209600Ejemplo:
345600
Rango requerido:
1024 <= x <= 262144Ejemplo:
262144
Rango requerido:
0 <= x <= 900Ejemplo:
0
Rango requerido:
0 <= x <= 20Ejemplo:
0
Rango requerido:
60 <= x <= 86400Ejemplo:
300
Solo colas FIFO.
Ejemplo:
false
UUID, CRN o nombre de la clave KMS en la cuenta. Omítalo para usar la clave de la plataforma.
Ejemplo:
"crn:kms:sa-saopaulo-1:acme:key/service-key"
UUID, CRN o nombre de la cola de destino en la cuenta. Se resuelve una vez y se almacena como UUID inmutable. Debe ser de la misma cuenta, región y tipo, y distinta del origen. La sintaxis, tipo o región inválidos devuelven 400; los destinos inexistentes o de otra cuenta devuelven 404. No hay búsqueda alternativa.
Show child attributes
Show child attributes
Show child attributes
Show child attributes
Ejemplo:
{
"environment": "production",
"team": "backend"
}
Respuesta
Cola creada.
Show child attributes
Show child attributes