SuperAPI AI 工具集

bullmq

智能体与模型

查看项目

更新于 10-15 23:31

技能介绍

BullMQ 是面向 Node.js 的 Redis 后端队列系统,核心类为 Queue、Worker、QueueEvents、FlowProducer。安装命令为 yarn add bullmq,要求 Redis 5.0+ 且 maxmemory-policy=noeviction。

用途:创建队列与 Worker、添加任务、处理任务生命周期与事件,以及使用 FlowProducer 和调度器。

主要能力:Queue 支持 add、addBulk、pause、resume、obliterate、close,任务选项含 delay、priority、attempts、backoff、removeOnComplete、removeOnFail。Worker 支持并发、autorun、运行时调整 concurrency,处理器接收 job、token、signal。事件分 Worker 本地事件(completed、failed、progress、drained、error)与 QueueEvents 全局事件(completed、failed、progress、waiting、active、delayed、deduplicated)。任务状态包括 wait、prioritized、delayed、active、completed、failed、waiting-children。

使用方式:连接可传配置或复用 ioredis 实例;Worker 要求 maxRetriesPerRequest: null,不要用 ioredis 的 keyPrefix,改用 BullMQ 的 prefix;QueueEvents 不能共享连接。TypeScript 泛型可标注任务数据与返回值。

限制:资料未提供收费、价格、平台与效果信息;高级主题细节见对应参考文件。