Actualizar configuración de la suscripción
curl --request PATCH \
--url https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id} \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"raw_message_delivery": true,
"filter_policy": {
"event": [
"order.created",
"order.paid"
],
"environment": [
"production"
],
"amount": [
{
"numeric": [
">=",
100,
"<",
1000
]
}
],
"test": [
{
"exists": false
}
]
},
"delivery_policy": {
"max_attempts": 6,
"min_delay_seconds": 20,
"max_delay_seconds": 1200,
"timeout_seconds": 15
},
"tags": {
"environment": "production",
"team": "backend"
}
}
'import requests
url = "https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}"
payload = {
"raw_message_delivery": True,
"filter_policy": {
"event": ["order.created", "order.paid"],
"environment": ["production"],
"amount": [{ "numeric": [">=", 100, "<", 1000] }],
"test": [{ "exists": False }]
},
"delivery_policy": {
"max_attempts": 6,
"min_delay_seconds": 20,
"max_delay_seconds": 1200,
"timeout_seconds": 15
},
"tags": {
"environment": "production",
"team": "backend"
}
}
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.patch(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'PATCH',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({
raw_message_delivery: true,
filter_policy: {
event: ['order.created', 'order.paid'],
environment: ['production'],
amount: [{numeric: ['>=', 100, '<', 1000]}],
test: [{exists: false}]
},
delivery_policy: {
max_attempts: 6,
min_delay_seconds: 20,
max_delay_seconds: 1200,
timeout_seconds: 15
},
tags: {environment: 'production', team: 'backend'}
})
};
fetch('https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_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_URL => "https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "PATCH",
CURLOPT_POSTFIELDS => json_encode([
'raw_message_delivery' => true,
'filter_policy' => [
'event' => [
'order.created',
'order.paid'
],
'environment' => [
'production'
],
'amount' => [
[
'numeric' => [
'>=',
100,
'<',
1000
]
]
],
'test' => [
[
'exists' => false
]
]
],
'delivery_policy' => [
'max_attempts' => 6,
'min_delay_seconds' => 20,
'max_delay_seconds' => 1200,
'timeout_seconds' => 15
],
'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://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}"
payload := strings.NewReader("{\n \"raw_message_delivery\": true,\n \"filter_policy\": {\n \"event\": [\n \"order.created\",\n \"order.paid\"\n ],\n \"environment\": [\n \"production\"\n ],\n \"amount\": [\n {\n \"numeric\": [\n \">=\",\n 100,\n \"<\",\n 1000\n ]\n }\n ],\n \"test\": [\n {\n \"exists\": false\n }\n ]\n },\n \"delivery_policy\": {\n \"max_attempts\": 6,\n \"min_delay_seconds\": 20,\n \"max_delay_seconds\": 1200,\n \"timeout_seconds\": 15\n },\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
req, _ := http.NewRequest("PATCH", 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.patch("https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"raw_message_delivery\": true,\n \"filter_policy\": {\n \"event\": [\n \"order.created\",\n \"order.paid\"\n ],\n \"environment\": [\n \"production\"\n ],\n \"amount\": [\n {\n \"numeric\": [\n \">=\",\n 100,\n \"<\",\n 1000\n ]\n }\n ],\n \"test\": [\n {\n \"exists\": false\n }\n ]\n },\n \"delivery_policy\": {\n \"max_attempts\": 6,\n \"min_delay_seconds\": 20,\n \"max_delay_seconds\": 1200,\n \"timeout_seconds\": 15\n },\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Patch.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"raw_message_delivery\": true,\n \"filter_policy\": {\n \"event\": [\n \"order.created\",\n \"order.paid\"\n ],\n \"environment\": [\n \"production\"\n ],\n \"amount\": [\n {\n \"numeric\": [\n \">=\",\n 100,\n \"<\",\n 1000\n ]\n }\n ],\n \"test\": [\n {\n \"exists\": false\n }\n ]\n },\n \"delivery_policy\": {\n \"max_attempts\": 6,\n \"min_delay_seconds\": 20,\n \"max_delay_seconds\": 1200,\n \"timeout_seconds\": 15\n },\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}"
response = http.request(request)
puts response.read_body{
"subscription": {
"id": "b2c3d4e5-6f7a-4b8c-9d0e-1f2a3b4c5d6e",
"crn": "crn:notifications:sa-saopaulo-1:my-account:topic/orders/subscription/b2c3d4e5-6f7a-4b8c-9d0e-1f2a3b4c5d6e",
"protocol": "https",
"endpoint": "https://hooks.example.com/basaltic",
"status": "confirmed",
"raw_message_delivery": false,
"created_at": "2026-01-18T09:30:00Z",
"updated_at": "2026-01-18T09:31:00Z",
"filter_policy": {
"event": [
"order.created",
"order.paid"
],
"environment": [
"production"
],
"amount": [
{
"numeric": [
">=",
100,
"<",
1000
]
}
],
"test": [
{
"exists": false
}
]
},
"delivery_policy": {
"max_attempts": 6,
"min_delay_seconds": 20,
"max_delay_seconds": 1200,
"timeout_seconds": 15
},
"redrive_policy": {
"dead_letter_queue": {
"id": "c3d4e5f6-7a8b-4c9d-8e0f-1a2b3c4d5e6f",
"crn": "crn:queue:sa-saopaulo-1:my-account:queue/notification-failures",
"name": "notification-failures"
}
},
"confirmation_expires_at": "2026-01-21T09:30:00Z",
"confirmed_at": "2026-01-18T09:31:00Z",
"tags": {
"environment": "production",
"team": "backend"
}
}
}{
"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"
}
}Suscripciones
Actualizar configuración de la suscripción
Protocolo y destino son inmutables: cambiarlos enviaría mensajes a un destino que no confirmó la suscripción.
PATCH
/
v1
/
topics
/
{topic_id}
/
subscriptions
/
{subscription_id}
Actualizar configuración de la suscripción
curl --request PATCH \
--url https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id} \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"raw_message_delivery": true,
"filter_policy": {
"event": [
"order.created",
"order.paid"
],
"environment": [
"production"
],
"amount": [
{
"numeric": [
">=",
100,
"<",
1000
]
}
],
"test": [
{
"exists": false
}
]
},
"delivery_policy": {
"max_attempts": 6,
"min_delay_seconds": 20,
"max_delay_seconds": 1200,
"timeout_seconds": 15
},
"tags": {
"environment": "production",
"team": "backend"
}
}
'import requests
url = "https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}"
payload = {
"raw_message_delivery": True,
"filter_policy": {
"event": ["order.created", "order.paid"],
"environment": ["production"],
"amount": [{ "numeric": [">=", 100, "<", 1000] }],
"test": [{ "exists": False }]
},
"delivery_policy": {
"max_attempts": 6,
"min_delay_seconds": 20,
"max_delay_seconds": 1200,
"timeout_seconds": 15
},
"tags": {
"environment": "production",
"team": "backend"
}
}
headers = {
"Authorization": "Bearer <token>",
"Content-Type": "application/json"
}
response = requests.patch(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'PATCH',
headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
body: JSON.stringify({
raw_message_delivery: true,
filter_policy: {
event: ['order.created', 'order.paid'],
environment: ['production'],
amount: [{numeric: ['>=', 100, '<', 1000]}],
test: [{exists: false}]
},
delivery_policy: {
max_attempts: 6,
min_delay_seconds: 20,
max_delay_seconds: 1200,
timeout_seconds: 15
},
tags: {environment: 'production', team: 'backend'}
})
};
fetch('https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_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_URL => "https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "PATCH",
CURLOPT_POSTFIELDS => json_encode([
'raw_message_delivery' => true,
'filter_policy' => [
'event' => [
'order.created',
'order.paid'
],
'environment' => [
'production'
],
'amount' => [
[
'numeric' => [
'>=',
100,
'<',
1000
]
]
],
'test' => [
[
'exists' => false
]
]
],
'delivery_policy' => [
'max_attempts' => 6,
'min_delay_seconds' => 20,
'max_delay_seconds' => 1200,
'timeout_seconds' => 15
],
'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://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}"
payload := strings.NewReader("{\n \"raw_message_delivery\": true,\n \"filter_policy\": {\n \"event\": [\n \"order.created\",\n \"order.paid\"\n ],\n \"environment\": [\n \"production\"\n ],\n \"amount\": [\n {\n \"numeric\": [\n \">=\",\n 100,\n \"<\",\n 1000\n ]\n }\n ],\n \"test\": [\n {\n \"exists\": false\n }\n ]\n },\n \"delivery_policy\": {\n \"max_attempts\": 6,\n \"min_delay_seconds\": 20,\n \"max_delay_seconds\": 1200,\n \"timeout_seconds\": 15\n },\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
req, _ := http.NewRequest("PATCH", 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.patch("https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"raw_message_delivery\": true,\n \"filter_policy\": {\n \"event\": [\n \"order.created\",\n \"order.paid\"\n ],\n \"environment\": [\n \"production\"\n ],\n \"amount\": [\n {\n \"numeric\": [\n \">=\",\n 100,\n \"<\",\n 1000\n ]\n }\n ],\n \"test\": [\n {\n \"exists\": false\n }\n ]\n },\n \"delivery_policy\": {\n \"max_attempts\": 6,\n \"min_delay_seconds\": 20,\n \"max_delay_seconds\": 1200,\n \"timeout_seconds\": 15\n },\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://notifications.{region}.basaltic.sh/v1/topics/{topic_id}/subscriptions/{subscription_id}")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Patch.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n \"raw_message_delivery\": true,\n \"filter_policy\": {\n \"event\": [\n \"order.created\",\n \"order.paid\"\n ],\n \"environment\": [\n \"production\"\n ],\n \"amount\": [\n {\n \"numeric\": [\n \">=\",\n 100,\n \"<\",\n 1000\n ]\n }\n ],\n \"test\": [\n {\n \"exists\": false\n }\n ]\n },\n \"delivery_policy\": {\n \"max_attempts\": 6,\n \"min_delay_seconds\": 20,\n \"max_delay_seconds\": 1200,\n \"timeout_seconds\": 15\n },\n \"tags\": {\n \"environment\": \"production\",\n \"team\": \"backend\"\n }\n}"
response = http.request(request)
puts response.read_body{
"subscription": {
"id": "b2c3d4e5-6f7a-4b8c-9d0e-1f2a3b4c5d6e",
"crn": "crn:notifications:sa-saopaulo-1:my-account:topic/orders/subscription/b2c3d4e5-6f7a-4b8c-9d0e-1f2a3b4c5d6e",
"protocol": "https",
"endpoint": "https://hooks.example.com/basaltic",
"status": "confirmed",
"raw_message_delivery": false,
"created_at": "2026-01-18T09:30:00Z",
"updated_at": "2026-01-18T09:31:00Z",
"filter_policy": {
"event": [
"order.created",
"order.paid"
],
"environment": [
"production"
],
"amount": [
{
"numeric": [
">=",
100,
"<",
1000
]
}
],
"test": [
{
"exists": false
}
]
},
"delivery_policy": {
"max_attempts": 6,
"min_delay_seconds": 20,
"max_delay_seconds": 1200,
"timeout_seconds": 15
},
"redrive_policy": {
"dead_letter_queue": {
"id": "c3d4e5f6-7a8b-4c9d-8e0f-1a2b3c4d5e6f",
"crn": "crn:queue:sa-saopaulo-1:my-account:queue/notification-failures",
"name": "notification-failures"
}
},
"confirmation_expires_at": "2026-01-21T09:30:00Z",
"confirmed_at": "2026-01-18T09:31:00Z",
"tags": {
"environment": "production",
"team": "backend"
}
}
}{
"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"
}
}Requiere la acción IAM
notifications:UpdateSubscription. Consulte NOTIFICATIONS 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
Ejemplo:
"a1b2c3d4-5e6f-4a7b-8c9d-0e1f2a3b4c5d"
Ejemplo:
"b2c3d4e5-6f7a-4b8c-9d0e-1f2a3b4c5d6e"
Cuerpo
application/json
Ejemplo:
true
Filtra atributos de la publicación, no campos del cuerpo. Cada atributo debe coincidir con una alternativa: AND entre nombres y OR dentro de cada lista. Los nombres y comparaciones distinguen mayúsculas. Una política omitida o vacía acepta todos los mensajes.
Alternativas: cadenas o números exactos, u objetos con un operador: {"prefix": "order."}, {"suffix": ".failed"}, {"anything-but": ["debug", "trace"]}, {"exists": true}, {"exists": false} o {"numeric": [">=", 100, "<", 1000]}. Los prefijos y sufijos no pueden estar vacíos. anything-but acepta una cadena, número o lista de 1–50 valores.
Solo exists: false acepta un atributo ausente. La exclusión también exige presencia. Operadores numéricos: =, <, <=, > y >=; todos los pares deben ser verdaderos. Los valores no numéricos no coinciden. Los números simples comparan representaciones textuales; use numeric para la equivalencia entre "100" y "100.0".
Hasta 20 nombres no vacíos, con 1–50 alternativas por nombre. Un operador por objeto. No hay comodines, expresiones regulares, filtros del cuerpo ni operadores anidados. PATCH sustituye toda la política; {} la borra y omitirla la conserva. Consulte Políticas de filtro.
Show child attributes
Show child attributes
Ejemplo:
{
"event": ["order.created", "order.paid"],
"environment": ["production"],
"amount": [{ "numeric": [">=", 100, "<", 1000] }],
"test": [{ "exists": false }]
}
Política de reintentos. Los campos omitidos heredan el tema y después los valores predeterminados: 6 intentos, espera exponencial de 20s a 20min con variación aleatoria y timeout de 15s. La herencia se aplica por campo; cambiar max_attempts conserva la curva del tema.
Show child attributes
Show child attributes
Omitirlo conserva la cola de mensajes no entregados. Un dead_letter_queue vacío la elimina. Un nuevo destino vuelve a validar queue:SendMessage.
Show child attributes
Show child attributes
Show child attributes
Show child attributes
Ejemplo:
{
"environment": "production",
"team": "backend"
}
Respuesta
Suscripción actualizada.
Show child attributes
Show child attributes