- 稳定性
- 稳定
- 作用域
- 全局
- 边界
- packages/integrations/queue
email247billing89ai-tasks14webhooks31
| 状态 | Job | 队列 | 重试 | 耗时 | 时间 |
|---|---|---|---|---|---|
| 执行中 | job_9f3a2c | ai-tasks | 1/3 | 412 ms | 刚刚 |
| 成功 | job_8c41be | 1/3 | 184 ms | 12 秒前 | |
| 成功 | job_77d019 | billing | 1/3 | 76 ms | 48 秒前 |
| 失败 | job_6b22f4 | webhooks | 3/3 | 5,012 ms | 1 分钟前 |
| 等待中 | job_5a18ee | 2/3 | — | 2 分钟前 | |
| 成功 | job_4e0b7c | billing | 1/3 | 221 ms | 3 分钟前 |
吞吐量
1,247
+8.2%
条/分钟
成功率
99.4%
+0.3%
过去 60 分钟
平均延迟
184 ms
运行正常
使用方式queue.ts
typescriptqueue.ts
1import { getQueue, createJob } from "@nebutra/queue";
2
3// Auto-detects QStash, BullMQ, or memory from env.
4const queue = await getQueue();
5
6await queue.enqueue(
7 createJob("billing", "send-invoice", { orderId: order.id }, { tenantId }),
8);
9
10queue.registerHandler("billing", "send-invoice", async (job) => {
11 await sendInvoice(job.data.orderId);
12});