消息队列

托管消息队列：发布与消费消息、批量发送、死信队列（DLQ）、重投递与推送订阅。

概览

基础路径: https://api.infrai.cc/v1/queue

鉴权头: Authorization: Bearer $INFRAI_API_KEY

bash

# Call any /v1/queue capability over raw HTTP — no SDK to install.
# curl:
curl https://api.infrai.cc/v1/queue/... \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json"

方法

queue.publish

POST /v1/queue/publish

向队列发布消息，可选延迟。

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称。
`payload`	`object`	必填	消息负载。
`delay_seconds`	`number`	可选	投递前的延迟（秒）。
`idempotency_key`	`string`	可选	可选去重 key；相同重试将返回同一结果。

{ message_id }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/publish \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "orders", "payload": {"order_id": "o_123"}, "priority": 5}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/publish",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': 'orders', 'payload': {'order_id': 'o_123'}, 'priority': 5},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/publish",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "payload": {"order_id": "o_123"}, "priority": 5}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/publish",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "payload": {"order_id": "o_123"}, "priority": 5}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.create

POST /v1/queue/create

创建一个消息队列

参数

名称	类型	必填	说明
`name`	`string`	必填	队列名称
`type`	`"standard" \| "fifo"`	可选	队列类型：standard 标准 / fifo 先进先出
`dead_letter_queue`	`string`	可选	接收失败消息的死信队列名（须已存在）
`max_retries`	`number`	可选	转入 DLQ 前允许的 nack 次数
`message_retention_days`	`number`	可选	消息保留天数
`visibility_timeout_default`	`number`	可选	默认可见性超时（租约）秒数
`enable_priority`	`boolean`	可选	是否启用优先级
`idempotency_key`	`string`	可选	幂等键，避免重复创建

QueueRecord { queue, type, dead_letter_queue?, max_retries, visibility_timeout_default }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/create \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"name": "..."}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/create",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'name': '...'},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/create",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"name": "..."}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/create",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"name": "..."}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.get

GET /v1/queue/get/{queue}

获取队列配置详情

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称

QueueRecord { queue, type, dead_letter_queue?, max_retries, visibility_timeout_default }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X GET https://api.infrai.cc/v1/queue/get/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY"

python

import os, requests

resp = requests.get(
    "https://api.infrai.cc/v1/queue/get/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/get/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/get/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.list

GET /v1/queue/list

分页列出所有队列

参数

名称	类型	必填	说明
`cursor`	`string`	可选	分页游标，来自上一页 next_cursor
`limit`	`number`	可选	每页返回数量

{ items: QueueRecord[], next_cursor? }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X GET https://api.infrai.cc/v1/queue/list \
  -H "Authorization: Bearer $INFRAI_API_KEY"

python

import os, requests

resp = requests.get(
    "https://api.infrai.cc/v1/queue/list",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/list",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/list",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.update

PATCH /v1/queue/update/{queue}

更新队列配置

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`dead_letter_queue`	`string`	可选	死信队列名
`max_retries`	`number`	可选	转入 DLQ 前允许的 nack 次数
`message_retention_days`	`number`	可选	消息保留天数
`visibility_timeout_default`	`number`	可选	默认可见性超时秒数
`enable_priority`	`boolean`	可选	是否启用优先级
`idempotency_key`	`string`	可选	幂等键，避免重复执行

QueueRecord { queue, max_retries, visibility_timeout_default }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X PATCH https://api.infrai.cc/v1/queue/update/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{}'

python

import os, requests

resp = requests.patch(
    "https://api.infrai.cc/v1/queue/update/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/update/QUEUE",
  {
    method: "PATCH",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/update/QUEUE",
  {
    method: "PATCH",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.delete

DELETE /v1/queue/delete/{queue}

删除一个队列

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`idempotency_key`	`string`	可选	幂等键，避免重复执行

{ queue, deleted }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X DELETE https://api.infrai.cc/v1/queue/delete/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY"

python

import os, requests

resp = requests.delete(
    "https://api.infrai.cc/v1/queue/delete/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/delete/QUEUE",
  {
    method: "DELETE",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/delete/QUEUE",
  {
    method: "DELETE",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.purge

POST /v1/queue/purge/{queue}

清空队列中所有消息

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`idempotency_key`	`string`	可选	幂等键，避免重复执行

{ queue, purged }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/purge/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "..."}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/purge/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': '...'},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/purge/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "..."}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/purge/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "..."}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.stats

GET /v1/queue/stats/{queue}

获取队列统计指标

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称

QueueStats { queue, available, in_flight, dlq, oldest_age_seconds? }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X GET https://api.infrai.cc/v1/queue/stats/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY"

python

import os, requests

resp = requests.get(
    "https://api.infrai.cc/v1/queue/stats/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/stats/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/stats/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.publish_batch

POST /v1/queue/publish_batch

批量发布多条消息到队列

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`messages`	`QueueMessage[]`	必填	待发布的消息数组
`idempotency_key`	`string`	可选	幂等键，避免重复发布

{ message_ids }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/publish_batch \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "...", "messages": []}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/publish_batch",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': '...', 'messages': []},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/publish_batch",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "...", "messages": []}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/publish_batch",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "...", "messages": []}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.consume

POST /v1/queue/consume

从队列拉取一批消息消费

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`max_messages`	`number`	可选	单次最多拉取的消息数
`visibility_timeout`	`number`	可选	本批消息的租约秒数；默认取队列配置

{ messages: QueueMessage[] }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/consume \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "..."}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/consume",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': '...'},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/consume",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "..."}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/consume",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "..."}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.ack

POST /v1/queue/ack

确认一条已消费的消息

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`message_id`	`string`	必填	消息 ID
`idempotency_key`	`string`	可选	幂等键，避免重复执行

{ message_id, acked }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/ack \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "...", "message_id": "..."}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/ack",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': '...', 'message_id': '...'},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/ack",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "...", "message_id": "..."}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/ack",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "...", "message_id": "..."}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.nack

POST /v1/queue/nack

否认一条消息，可重新入队或转入死信

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`message_id`	`string`	必填	消息 ID
`requeue`	`boolean`	可选	true 重新入队；false 直接转入死信
`idempotency_key`	`string`	可选	幂等键，避免重复执行

{ message_id, nacked, requeued }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/nack \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "...", "message_id": "..."}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/nack",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': '...', 'message_id': '...'},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/nack",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "...", "message_id": "..."}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/nack",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "...", "message_id": "..."}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.dlq.list

GET /v1/queue/dlq/list/{queue}

分页列出死信队列中的消息

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`cursor`	`string`	可选	分页游标，来自上一页 next_cursor
`limit`	`number`	可选	每页返回数量

{ items: QueueMessage[], next_cursor? }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X GET https://api.infrai.cc/v1/queue/dlq/list/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY"

python

import os, requests

resp = requests.get(
    "https://api.infrai.cc/v1/queue/dlq/list/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/dlq/list/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/dlq/list/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.dlq.redrive

POST /v1/queue/dlq/redrive/{queue}

将死信消息重投回原队列

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`message_id`	`string`	可选	重投单条消息的 ID；省略则批量重投
`since`	`string`	可选	批量重投：该时刻及之后进入死信的全部消息
`idempotency_key`	`string`	可选	幂等键，避免重复重投

{ queue, redriven }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/dlq/redrive/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "orders", "max_messages": 100}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/dlq/redrive/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': 'orders', 'max_messages': 100},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/dlq/redrive/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "max_messages": 100}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/dlq/redrive/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "max_messages": 100}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

queue.push_subscribe

POST /v1/queue/push_subscribe/{queue}

为队列配置推送订阅

参数

名称	类型	必填	说明
`queue`	`string`	必填	队列名称
`url`	`string`	必填	https 推送目标地址（经 SSRF 校验）
`secret`	`string`	可选	对推送请求做 HMAC 签名的密钥
`max_retries`	`number`	可选	推送失败重试次数
`visibility_timeout`	`number`	可选	可见性超时秒数
`dead_letter_queue`	`string`	可选	死信队列名
`idempotency_key`	`string`	可选	幂等键，避免重复订阅

PushSubscription { subscription_id, queue, url }

示例

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

curl -X POST https://api.infrai.cc/v1/queue/push_subscribe/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "orders", "forward_to": "https://api.acme.com/order-handler"}'

python

import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/push_subscribe/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': 'orders', 'forward_to': 'https://api.acme.com/order-handler'},
)
resp.raise_for_status()
print(resp.json())

javascript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/push_subscribe/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "forward_to": "https://api.acme.com/order-handler"}),
  },
);
console.log(await resp.json());

typescript

const resp = await fetch(
  "https://api.infrai.cc/v1/queue/push_subscribe/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "forward_to": "https://api.acme.com/order-handler"}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

全部能力

本模块全部已路由能力——完整的对外 REST 契约。上方方法是带讲解的入门示例,此表是完整参考。

能力	端点	说明
`queue.ack`	`POST /v1/queue/ack`	Acknowledge (ack) a consumed message to remove it from the queue.
`queue.consume`	`POST /v1/queue/consume`	Pull a batch of messages from a queue for processing.
`queue.create`	`POST /v1/queue/create`	Create a message queue (standard or FIFO, with optional dead-letter queue).
`queue.delete`	`DELETE /v1/queue/delete/{queue}`	Delete a message queue and discard all of its pending messages (use queue.purge to keep the queue); idempotent.
`queue.dlq.list`	`GET /v1/queue/dlq/list/{queue}`	List messages in a queue's dead-letter queue (DLQ) with pagination.
`queue.dlq.redrive`	`POST /v1/queue/dlq/redrive/{queue}`	Redrive dead-letter messages back to the source queue, individually or in bulk.
`queue.get`	`GET /v1/queue/get/{queue}`	Retrieve a queue's configuration details.
`queue.list`	`GET /v1/queue/list`	List all message queues with pagination.
`queue.nack`	`POST /v1/queue/nack`	Negatively acknowledge (nack) a message to requeue it or route it to the DLQ.
`queue.publish`	`POST /v1/queue/publish`	Publish a single message to a queue (idempotent).
`queue.publish_batch`	`POST /v1/queue/publish_batch`	Publish multiple messages to a queue in a single batch.
`queue.purge`	`POST /v1/queue/purge/{queue}`	Purge all messages from a queue.
`queue.push_subscribe`	`POST /v1/queue/push_subscribe/{queue}`	Configure a push subscription to deliver queue messages to a callback URL.
`queue.stats`	`GET /v1/queue/stats/{queue}`	Retrieve queue metrics: available, in-flight, and dead-lettered message counts.
`queue.update`	`PATCH /v1/queue/update/{queue}`	Update a queue's DLQ, retry, and retention settings.

完整示例

本模块的生产级端到端范例:先一次性配置,再运行业务流程,尽量覆盖本模块的多数 API。

单文件可运行 Python 程序(仅标准库、无 SDK):拷贝后填入 INFRAI_API_KEY 运行,即可按真实业务流逐步体验本模块核心 API——每一步都真实调用并计费,后续步骤复用前一步返回的真实字段。12 行 helper 就是全部集成代码。

python

#!/usr/bin/env python3
"""Infrai · queue — runnable real-app example (single file, zero deps).

Copy this file, set your key, run it: every step is a REAL call to
api.infrai.cc, billed at the real (tiny) per-call price, printing the
live JSON response. Get a key at https://infrai.cc/login (Google/
GitHub sign-in grants $2 free credit); add funds at
https://infrai.cc/billing. No SDK — the 12-line helper below is the
entire integration."""
import json
import os
from urllib import error, request

KEY = os.environ.get("INFRAI_API_KEY") or "ifr_..."  # <- your key
BASE = "https://api.infrai.cc"


# Same raw HTTPS POST/GET as every per-method example on this page —
# wrapped once for reuse. There is nothing else to it: no SDK.
def infrai(method, path, body=None):
    req = request.Request(
        BASE + path, method=method,
        data=json.dumps(body).encode() if body is not None else None,
        headers={"Authorization": f"Bearer {KEY}",
                 "Content-Type": "application/json"})
    try:
        with request.urlopen(req, timeout=60) as r:
            return json.loads(r.read())
    except error.HTTPError as e:
        return json.loads(e.read())


def show(label, resp):
    print(f"\n== {label} ==")
    print(json.dumps(resp, indent=2, ensure_ascii=False))
    return resp


# 1) queue.create — POST /v1/queue/create · Create a message queue (standard or FIFO, with optional dead-letter queue).
r1 = show("queue.create", infrai("POST", "/v1/queue/create", {"name":"jobs"}))

# 2) queue.publish — POST /v1/queue/publish · Publish a single message to a queue (idempotent).
r2 = show("queue.publish", infrai("POST", "/v1/queue/publish", {"queue":"jobs","payload":{"hello":"world"}}))

# 3) queue.consume — POST /v1/queue/consume · Pull a batch of messages from a queue for processing.
r3 = show("queue.consume", infrai("POST", "/v1/queue/consume", {"queue":"jobs","max_messages":1}))

一次性前置(每个范例都假定已完成):

bash

# No SDK to install — every call is a plain HTTPS request.
# Get a project key by signing in at https://infrai.cc/login (Google/GitHub gives
# you $2 free credit; email sign-in starts at $0). On 402 INSUFFICIENT_CREDIT, add
# funds at https://infrai.cc/billing (or POST /v1/account/topup and open the
# returned checkout_url).
export INFRAI_API_KEY="ifr_..."

bash

# 1) Auth: every call is a raw HTTPS request to the Infrai gateway carrying
#    only your project key. No SDK, no install.
#    Get your key: sign in with Google/GitHub at https://infrai.cc/login for a
#    project key + $2 free credit (email sign-in starts at $0). On 402
#    INSUFFICIENT_CREDIT, add funds at https://infrai.cc/billing (or POST
#    /v1/account/topup and open the returned checkout_url).
export INFRAI_API_KEY="ifr_..."   # from https://infrai.cc/login


# 2) queue.publish
curl -X POST https://api.infrai.cc/v1/queue/publish \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "orders", "payload": {"order_id": "o_123"}, "priority": 5}'

# 3) queue.create
curl -X POST https://api.infrai.cc/v1/queue/create \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"name": "..."}'

# 4) queue.get
curl -X GET https://api.infrai.cc/v1/queue/get/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY"

# 5) queue.list
curl -X GET https://api.infrai.cc/v1/queue/list \
  -H "Authorization: Bearer $INFRAI_API_KEY"

# 6) queue.update
curl -X PATCH https://api.infrai.cc/v1/queue/update/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{}'

# 7) queue.delete
curl -X DELETE https://api.infrai.cc/v1/queue/delete/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY"

# 8) queue.purge
curl -X POST https://api.infrai.cc/v1/queue/purge/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"queue": "..."}'

# 9) queue.stats
curl -X GET https://api.infrai.cc/v1/queue/stats/QUEUE \
  -H "Authorization: Bearer $INFRAI_API_KEY"

python

# 1) Auth: every call is a raw HTTPS request carrying only your project key.
#    No SDK to install — just the `requests` library.
import os, requests

BASE = "https://api.infrai.cc"
HEADERS = {
    "Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}",
    "Content-Type": "application/json",
}


# 2) queue.publish
import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/publish",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': 'orders', 'payload': {'order_id': 'o_123'}, 'priority': 5},
)
resp.raise_for_status()
print(resp.json())

# 3) queue.create
import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/create",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'name': '...'},
)
resp.raise_for_status()
print(resp.json())

# 4) queue.get
import os, requests

resp = requests.get(
    "https://api.infrai.cc/v1/queue/get/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

# 5) queue.list
import os, requests

resp = requests.get(
    "https://api.infrai.cc/v1/queue/list",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

# 6) queue.update
import os, requests

resp = requests.patch(
    "https://api.infrai.cc/v1/queue/update/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={},
)
resp.raise_for_status()
print(resp.json())

# 7) queue.delete
import os, requests

resp = requests.delete(
    "https://api.infrai.cc/v1/queue/delete/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

# 8) queue.purge
import os, requests

resp = requests.post(
    "https://api.infrai.cc/v1/queue/purge/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
    json={'queue': '...'},
)
resp.raise_for_status()
print(resp.json())

# 9) queue.stats
import os, requests

resp = requests.get(
    "https://api.infrai.cc/v1/queue/stats/QUEUE",
    headers={"Authorization": f"Bearer {os.environ['INFRAI_API_KEY']}"},
)
resp.raise_for_status()
print(resp.json())

javascript

// 1) Auth: every call is a raw HTTPS request carrying only your project key.
//    No SDK to install — just the built-in fetch().
const BASE = "https://api.infrai.cc";
const HEADERS = {
  "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
  "Content-Type": "application/json",
};


// 2) queue.publish
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/publish",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "payload": {"order_id": "o_123"}, "priority": 5}),
  },
);
console.log(await resp.json());

// 3) queue.create
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/create",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"name": "..."}),
  },
);
console.log(await resp.json());

// 4) queue.get
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/get/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

// 5) queue.list
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/list",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

// 6) queue.update
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/update/QUEUE",
  {
    method: "PATCH",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({}),
  },
);
console.log(await resp.json());

// 7) queue.delete
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/delete/QUEUE",
  {
    method: "DELETE",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

// 8) queue.purge
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/purge/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "..."}),
  },
);
console.log(await resp.json());

// 9) queue.stats
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/stats/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
console.log(await resp.json());

typescript

// 1) Auth: every call is a raw HTTPS request carrying only your project key.
//    No SDK to install — just the built-in fetch(), typed.
const BASE = "https://api.infrai.cc";
const HEADERS: Record<string, string> = {
  "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
  "Content-Type": "application/json",
};


// 2) queue.publish
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/publish",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "orders", "payload": {"order_id": "o_123"}, "priority": 5}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

// 3) queue.create
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/create",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"name": "..."}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

// 4) queue.get
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/get/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

// 5) queue.list
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/list",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

// 6) queue.update
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/update/QUEUE",
  {
    method: "PATCH",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

// 7) queue.delete
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/delete/QUEUE",
  {
    method: "DELETE",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

// 8) queue.purge
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/purge/QUEUE",
  {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({"queue": "..."}),
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);

// 9) queue.stats
const resp = await fetch(
  "https://api.infrai.cc/v1/queue/stats/QUEUE",
  {
    method: "GET",
    headers: {
      "Authorization": `Bearer ${process.env.INFRAI_API_KEY}`,
    },
  },
);
if (!resp.ok) throw new Error(`infrai ${resp.status}`);
const data: unknown = await resp.json();
console.log(data);