后端消息队列任务调度【免费下载链接】bullmqBullMQ - Message Queue and Batch processing for NodeJS, Python, .NET, Elixir, Rust and PHP based on Redis or PostgreSQL项目地址https://gitcode.com/gh_mirrors/bu/bullmq点击查看免费下载导读本文以 BullMQ 仓库中 Python 客户端变更日志 为骨架梳理 v3.0.0 至 v3.2.6 的版本演进脉络核心主线是 v3 引入的**可插拔队列后端pluggable queue backends**架构——IQueueBackend抽象让同一套高层 API 同时运行在 Redis 与 PostgreSQL 之上随后 v3.1 与 v3.2 分别带来处理器控制的延迟调度DelayedErrorJob.moveToDelayed与去重查询能力Queue.getDeduplicationJobId。读完本文你将理解 v3 破坏性变更的迁移要点、后端抽象的工作原理以及这些新特性在实际代码中的调用方式。版本总览v3 主线与发布时间线截至 changelog 记录的最新版本 v3.2.62026-09-21Python 客户端 v3 系列沿一条清晰主线演进版本时间类型核心内容3.0.02026-07-30主版本发布可插拔队列后端引入IQueueBackend抽象、Redis 与 PostgreSQL 后端含多项破坏性变更3.0.12026-07-31修复补全发布包缺失的 SQL 文件影响 elixir/python3.0.22026-07-31修复redis 依赖升级至 v7.4.1PostgreSQL schema 对象去除冗余的bullmq_前缀3.0.32026-08-01修复Python 依赖批量更新3.0.42026-08-05修复job scheduler 可推进并支持 PostgreSQL 后端3.0.52026-08-25修复worker 存储失败原因时不再做额外 JSON 编码3.0.62026-08-25性能处理 deferred failures 时不再计入速率限制同步 elixir/rust/dotnet3.1.02026-08-28特性新增DelayedError与Job.moveToDelayed支持处理器控制的延迟3.1.12026-08-29修复将maximumBlockTimeout委托给后端Python 依赖更新3.2.02026-08-31特性新增Queue.getDeduplicationJobId方法3.2.1 ~ 3.2.62026-09 上旬修复依赖更新v3.2.3 修复 deduplication key 残留问题整条 v3 线的设计意图非常集中用后端抽象统一多语言客户端的数据存储语义并围绕去重、延迟、调度补齐与 Node.js 客户端对齐的能力。3.0.0可插拔队列后端架构IQueueBackend 抽象高层类不再直连数据存储v3 的核心变革是引入IQueueBackend抽象。在 Python 实现中这一契约由 python/bullmq/backend.py 中的Backend抽象基类表达它把队列语义move job to active、extend lock、promote job……与底层数据存储解耦高层类Queue、Worker、Job、FlowProducer只依赖该抽象从不直接操作数据存储客户端。从源码结构看该抽象按职责分组定义了几十项操作连接生命周期waitUntilReady、close、disconnect、setName队列身份与建键qualifiedName、keys、toKey、clientName添加任务addJob、addJobs批量、addFlow跨队列原子插入任务树状态迁移moveToActive、moveToCompleted、moveToFailed、moveToDelayed、moveToWaitingChildren、retryJob、reprocessJob、promote、moveStalledJobsToWait批量管理retryJobs、promoteJobs、pause、drain、cleanJobsInSet、obliterate、remove锁extendLock、extendLocks任务变更与查询updateData、updateProgress、changePriority、addLog、getState、getJobData、getJobLogs、getCounts、getRanges等调度器addJobScheduler、updateJobSchedulerNextMillis、removeJobScheduler、getJobScheduler(s)、getJobSchedulersCountworker 阻塞原语waitForJob。抽象基类的设计有一个值得注意的细节接口故意不暴露任何连接或事务类型——具体适配器自己持有连接调用方从不把连接或事务穿透过某个操作见 backend.py 的 design notes。这让FlowProducer可以通过forQueue拿到绑定到同一连接的兄弟后端从而跨队列原子提交任务树。内置实现Redis 与 PostgreSQL 双后端内置实现有两个python/bullmq/backends/redis_backend.py 与 python/bullmq/backends/postgres_backend.py均实现同一契约。Redis 后端直接把操作映射到 Lua 脚本与 Redis 命令。例如getDeduplicationJobId是对dededuplicationkey 命名空间的一次普通GET见 redis_backend.py 中注释底层脚本注册表见 python/bullmq/redis_connection.py如moveToDelayed对应moveToDelayed-11.lua。PostgreSQL 后端以 schema 为命名空间keys为空、toKey直接拼queue:type阻塞原语基于LISTEN/NOTIFY而非轮询见 postgres_backend.py 中的实现注释。v3.0.2 还清理了 schema 对象中冗余的bullmq_前缀v3.0.4 让 job scheduler 支持推进并运行在 PostgreSQL 后端之上。注入方式BackendFactory后端不是由高层类自行 new 出来的而是通过BackendFactoryCallable[..., Backend]定义于 backend.py注入。changelog 明确指出The optional Connection constructor parameter is replaced by an optional BackendFactory。默认工厂是create_redis_backend用户可注入自定义工厂以切换到 PostgreSQL 或未来其他数据存储且无需改动Queue/Worker/Job/FlowProducer任何一行代码。测试侧的证据可见 python/tests/postgres_backend_test.py它验证了 Postgres 后端的maximumBlockTimeout特性详见下文 v3.1.1 一节。3.0.0 破坏性变更迁移核对清单changelog 用一整节列出了 v3.0.0 的 BREAKING CHANGES这是升级时最需要逐条核对的清单高层类不再暴露 Redis 内部实现可选的Connection构造参数替换为可选的BackendFactoryQueue#client、Queue#redisVersion、Queue#databaseType、Worker#blockingClient、FlowProducer#client全部移除如需访问原始 Redis 客户端通过getBackend()返回的RedisQueueBackend获取Worker#waitUntilReady()现在解析为void而不是 Redis 客户端。移除已废弃的 debounce 选项与Job#debounceId属性改用 deduplication 与Job#deduplicationId。对应的debounced事件也被移除请监听deduplicated事件。FlowJob 区分父节点与叶子节点父流程节点不再允许 deduplication。paused 状态从JobType与Queue#getJobCounts()默认结果中移除暂停队列中的任务以 waiting 表示。Redis 公共实现的部分导出被移除Scripts、createScripts、JobJsonRaw、RedisJobOptions不再公开请改用后端 API。迁移路径的总体方向是把从 Redis 细节出发的用法改为从队列语义出发的用法——通过后端抽象表达意图而不是直接操作客户端、脚本或键。3.1.0处理器控制的延迟DelayedErrorJob.moveToDelayedv3.1.0 为 Python 客户端带来一个与 Node.js 客户端对齐的能力处理器可以在执行过程中自主决定把任务推迟到未来某个时间点而不是依赖任务的初始delay配置或失败重试的 backoff。用法与语义在处理器内部调用await job.moveToDelayed(timestamp, token)其中timestamp是任务应回到wait状态的时间戳毫秒然后抛出DelayedError让 worker 知道这个任务既不要完成也不要失败。实现位于 python/bullmq/job.pymoveToDelayed只在任务处于 active即从处理器内部调用时允许计算delay timestamp - now并通过后端moveToDelayed(..., {skipAttempt: True})把任务放入延迟集合——skipAttempt: True意味着这次推迟不计入attemptsMade不消耗重试次数。异常类型与 worker 的处理DelayedError定义在 python/bullmq/custom_errors/delayed_error.py并通过 python/bullmq/init.py 从bullmq顶层导出可以直接from bullmq import DelayedError有 python/tests/test_imports.py 的导入测试作证。在 worker 侧python/bullmq/worker.py 的processJob中显式捕获(DelayedError, WaitingChildrenError)并直接返回——不进入moveToCompleted也不进入moveToFailed流程。也就是说DelayedError只负责让 worker 走开真正停车的是moveToDelayed调用如果只抛异常而不调用moveToDelayed任务不会被推迟。这一语义在 python/tests/worker_test.py 中有专门的测试用例验证先moveToDelayed再raise DelayedError()。典型应用场景任务在运行中发现条件还不满足、几分钟后再试且希望保持锁的语义与重试次数不被浪费。3.1.1将maximumBlockTimeout委托给后端v3.1.1 的修复delegate maximumBlockTimeout to the backend (python)让阻塞超时上限变成后端专属属性。在抽象基类 backend.py 中maximumBlockTimeout默认返回 10 秒——这是 Redis 阻塞原语BZPOPMIN类操作的上限见 worker.py 中关于default_maximum_block_timeout的注释。而 postgres_backend.py 将其覆盖为 3600 秒理由写得很清楚PostgreSQL 的LISTEN/NOTIFY让连接保持打开并自动重新武装到下一个到期任务没有 Redis 那种为廉价重连而限制 10s的需求更大的上限能让空闲 worker 真正安静下来而不是每 10 秒轮询一次——这对按空闲挂起的 serverless Postgres 尤其重要。此外还设置了minimumBlockTimeout与capabilities如canBlockFor1Ms、canDoubleTimeout等能力标记。worker 侧通过getattr(self.backend, maximumBlockTimeout, None)探测后端属性后端没有该属性时回退到默认值见 worker.py 与 python/tests/worker_disconnect_test.py 中后端缺失该属性时回退为 10的测试。3.2.0Queue.getDeduplicationJobIdv3.2.0 为Queue新增getDeduplicationJobId方法用于根据去重标识反查任务 ID。调用方式job_id await queue.getDeduplicationJobId(my-dedup-id)高层实现位于 python/bullmq/queue.py它直接把请求转发给后端抽象return await self.backend.getDeduplicationJobId(id)。两个后端各自的实现Redis 后端对{keys[de]}:{id}做一次普通GET——de即 deduplication key 命名空间见 redis_backend.py注释明确说明这与 Node.js 客户端的Queue#getDeduplicationJobId对齐PostgreSQL 后端在 postgres_backend.py 中有对应实现其 SQL 语句见仓库的 PostgreSQL 命令目录如 python/bullmq/postgres/commands/get_deduplication_job_id.sql。配套测试在 python/tests/deduplication_test.py覆盖了缺失 ID返回空、任务完成后去重键被清理返回空、共享去重 ID 指向同一任务等多种场景。这个方法的实用价值在于任务因去重被跳过时调用方仍能拿到真正干活的那个任务的 ID用于查询状态或关联业务。其余修复与性能改进一览v3.0.5 失败原因存储worker 存储失败原因时不再做额外 JSON 编码——moveToFailedArgs中failedReason直接作为参数传给moveToFinished见 python/bullmq/scripts.py修复了失败原因被双重编码的问题对应 issue #4596。v3.0.6 速率限制处理 deferred failures 时不再计入速率限制窗口——失败任务的处理不再抢占限流配额这在重试风暴场景下能显著改善吞吐同步了 elixir/rust/dotnet 的行为。v3.2.3 去重键清理当任务键已不存在时删除残留的 deduplication key——修复了去重 ID 长期占用导致新任务被误判为重复的问题跨 python/elixir/php/rust/dotnet 同步。v3.0.1 发布完整性补全发布包中缺失的 SQL 文件影响 Python 与 Elixir 客户端确保 PostgreSQL 后端开箱即用。依赖维护v3.0.2 升级 redis 至 v7.4.1v3.2.1 升级 psycopg 至 v3.3.5v3.2.2 升级 semver 至 v3.1.0v3.2.4 ~ v3.2.6 批量更新 Python 依赖含 virtualenv v21.9.0。如何在仓库中跟进后续版本当前仓库的 Python 客户端实现位于 python/ 目录除 changelog 外还可参考顶层导出python/bullmq/init.py含DelayedError、WaitingChildrenError、UnrecoverableError等后端契约与实现python/bullmq/backend.py、python/bullmq/backends/高层类python/bullmq/queue.py、python/bullmq/worker.py、python/bullmq/job.py、python/bullmq/job_scheduler.py、python/bullmq/flow_producer.pyRedis Lua 脚本注册表python/bullmq/scripts.pyPostgreSQL SQL 命令python/bullmq/postgres/commands/测试python/tests/deduplication、delay、job scheduler、postgres backend、worker disconnect 等主题均有覆盖。如果使用 pip 安装可通过pip install bullmq获取发布版本仓库内的 python/pyproject.toml 与 python/setup.py 定义了包元数据与依赖。本文所有行为描述均以当前仓库源码与 changelog 为准升级前请以你实际安装的版本对应的发布说明为准。赞分享后端消息队列任务调度【免费下载链接】bullmqBullMQ - Message Queue and Batch processing for NodeJS, Python, .NET, Elixir, Rust and PHP based on Redis or PostgreSQL项目地址https://gitcode.com/gh_mirrors/bu/bullmq点击查看免费下载相关推荐BullMQ Python 客户端 v3 演进解读可插拔后端架构、去重与延迟控制新能力全览BullMQ Python 客户端 v3 演进解读可插拔后端架构、去重与延迟控制新能力全览 导读本文以 python/CHANGELOG.md 为主体梳理后端消息队列任务调度Tcell v2 破坏性变更与新特性解析LazyGit 终端 UI 底座的演进Tcell v2 破坏性变更与新特性解析LazyGit 终端 UI 底座的演进 本文以 CHANGESv2.md https://link.gitcode.c开发工具CLI版本控制NetBox v3.6 版本全解析新特性、破坏性变更与 REST API 演进指南NetBox v3.6 版本全解析新特性、破坏性变更与 REST API 演进指南 NetBox v3.6 于 2023 年 8 月 30 日正式发布是 N后端网络数据建模上一篇TOML数据库配置终极指南简化数据库连接管理的完整教程 下一篇enzyme ReactWrapper 的 .length 属性统计包裹的 React 节点数量创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 BullMQ Python 客户端 v3 演进全解：可插拔后端架构、破坏性变更与新特性实战指南
后端消息队列任务调度【免费下载链接】bullmqBullMQ - Message Queue and Batch processing for NodeJS, Python, .NET, Elixir, Rust and PHP based on Redis or PostgreSQL项目地址https://gitcode.com/gh_mirrors/bu/bullmq点击查看免费下载导读本文以 BullMQ 仓库中 Python 客户端变更日志 为骨架梳理 v3.0.0 至 v3.2.6 的版本演进脉络核心主线是 v3 引入的**可插拔队列后端pluggable queue backends**架构——IQueueBackend抽象让同一套高层 API 同时运行在 Redis 与 PostgreSQL 之上随后 v3.1 与 v3.2 分别带来处理器控制的延迟调度DelayedErrorJob.moveToDelayed与去重查询能力Queue.getDeduplicationJobId。读完本文你将理解 v3 破坏性变更的迁移要点、后端抽象的工作原理以及这些新特性在实际代码中的调用方式。版本总览v3 主线与发布时间线截至 changelog 记录的最新版本 v3.2.62026-09-21Python 客户端 v3 系列沿一条清晰主线演进版本时间类型核心内容3.0.02026-07-30主版本发布可插拔队列后端引入IQueueBackend抽象、Redis 与 PostgreSQL 后端含多项破坏性变更3.0.12026-07-31修复补全发布包缺失的 SQL 文件影响 elixir/python3.0.22026-07-31修复redis 依赖升级至 v7.4.1PostgreSQL schema 对象去除冗余的bullmq_前缀3.0.32026-08-01修复Python 依赖批量更新3.0.42026-08-05修复job scheduler 可推进并支持 PostgreSQL 后端3.0.52026-08-25修复worker 存储失败原因时不再做额外 JSON 编码3.0.62026-08-25性能处理 deferred failures 时不再计入速率限制同步 elixir/rust/dotnet3.1.02026-08-28特性新增DelayedError与Job.moveToDelayed支持处理器控制的延迟3.1.12026-08-29修复将maximumBlockTimeout委托给后端Python 依赖更新3.2.02026-08-31特性新增Queue.getDeduplicationJobId方法3.2.1 ~ 3.2.62026-09 上旬修复依赖更新v3.2.3 修复 deduplication key 残留问题整条 v3 线的设计意图非常集中用后端抽象统一多语言客户端的数据存储语义并围绕去重、延迟、调度补齐与 Node.js 客户端对齐的能力。3.0.0可插拔队列后端架构IQueueBackend 抽象高层类不再直连数据存储v3 的核心变革是引入IQueueBackend抽象。在 Python 实现中这一契约由 python/bullmq/backend.py 中的Backend抽象基类表达它把队列语义move job to active、extend lock、promote job……与底层数据存储解耦高层类Queue、Worker、Job、FlowProducer只依赖该抽象从不直接操作数据存储客户端。从源码结构看该抽象按职责分组定义了几十项操作连接生命周期waitUntilReady、close、disconnect、setName队列身份与建键qualifiedName、keys、toKey、clientName添加任务addJob、addJobs批量、addFlow跨队列原子插入任务树状态迁移moveToActive、moveToCompleted、moveToFailed、moveToDelayed、moveToWaitingChildren、retryJob、reprocessJob、promote、moveStalledJobsToWait批量管理retryJobs、promoteJobs、pause、drain、cleanJobsInSet、obliterate、remove锁extendLock、extendLocks任务变更与查询updateData、updateProgress、changePriority、addLog、getState、getJobData、getJobLogs、getCounts、getRanges等调度器addJobScheduler、updateJobSchedulerNextMillis、removeJobScheduler、getJobScheduler(s)、getJobSchedulersCountworker 阻塞原语waitForJob。抽象基类的设计有一个值得注意的细节接口故意不暴露任何连接或事务类型——具体适配器自己持有连接调用方从不把连接或事务穿透过某个操作见 backend.py 的 design notes。这让FlowProducer可以通过forQueue拿到绑定到同一连接的兄弟后端从而跨队列原子提交任务树。内置实现Redis 与 PostgreSQL 双后端内置实现有两个python/bullmq/backends/redis_backend.py 与 python/bullmq/backends/postgres_backend.py均实现同一契约。Redis 后端直接把操作映射到 Lua 脚本与 Redis 命令。例如getDeduplicationJobId是对dededuplicationkey 命名空间的一次普通GET见 redis_backend.py 中注释底层脚本注册表见 python/bullmq/redis_connection.py如moveToDelayed对应moveToDelayed-11.lua。PostgreSQL 后端以 schema 为命名空间keys为空、toKey直接拼queue:type阻塞原语基于LISTEN/NOTIFY而非轮询见 postgres_backend.py 中的实现注释。v3.0.2 还清理了 schema 对象中冗余的bullmq_前缀v3.0.4 让 job scheduler 支持推进并运行在 PostgreSQL 后端之上。注入方式BackendFactory后端不是由高层类自行 new 出来的而是通过BackendFactoryCallable[..., Backend]定义于 backend.py注入。changelog 明确指出The optional Connection constructor parameter is replaced by an optional BackendFactory。默认工厂是create_redis_backend用户可注入自定义工厂以切换到 PostgreSQL 或未来其他数据存储且无需改动Queue/Worker/Job/FlowProducer任何一行代码。测试侧的证据可见 python/tests/postgres_backend_test.py它验证了 Postgres 后端的maximumBlockTimeout特性详见下文 v3.1.1 一节。3.0.0 破坏性变更迁移核对清单changelog 用一整节列出了 v3.0.0 的 BREAKING CHANGES这是升级时最需要逐条核对的清单高层类不再暴露 Redis 内部实现可选的Connection构造参数替换为可选的BackendFactoryQueue#client、Queue#redisVersion、Queue#databaseType、Worker#blockingClient、FlowProducer#client全部移除如需访问原始 Redis 客户端通过getBackend()返回的RedisQueueBackend获取Worker#waitUntilReady()现在解析为void而不是 Redis 客户端。移除已废弃的 debounce 选项与Job#debounceId属性改用 deduplication 与Job#deduplicationId。对应的debounced事件也被移除请监听deduplicated事件。FlowJob 区分父节点与叶子节点父流程节点不再允许 deduplication。paused 状态从JobType与Queue#getJobCounts()默认结果中移除暂停队列中的任务以 waiting 表示。Redis 公共实现的部分导出被移除Scripts、createScripts、JobJsonRaw、RedisJobOptions不再公开请改用后端 API。迁移路径的总体方向是把从 Redis 细节出发的用法改为从队列语义出发的用法——通过后端抽象表达意图而不是直接操作客户端、脚本或键。3.1.0处理器控制的延迟DelayedErrorJob.moveToDelayedv3.1.0 为 Python 客户端带来一个与 Node.js 客户端对齐的能力处理器可以在执行过程中自主决定把任务推迟到未来某个时间点而不是依赖任务的初始delay配置或失败重试的 backoff。用法与语义在处理器内部调用await job.moveToDelayed(timestamp, token)其中timestamp是任务应回到wait状态的时间戳毫秒然后抛出DelayedError让 worker 知道这个任务既不要完成也不要失败。实现位于 python/bullmq/job.pymoveToDelayed只在任务处于 active即从处理器内部调用时允许计算delay timestamp - now并通过后端moveToDelayed(..., {skipAttempt: True})把任务放入延迟集合——skipAttempt: True意味着这次推迟不计入attemptsMade不消耗重试次数。异常类型与 worker 的处理DelayedError定义在 python/bullmq/custom_errors/delayed_error.py并通过 python/bullmq/init.py 从bullmq顶层导出可以直接from bullmq import DelayedError有 python/tests/test_imports.py 的导入测试作证。在 worker 侧python/bullmq/worker.py 的processJob中显式捕获(DelayedError, WaitingChildrenError)并直接返回——不进入moveToCompleted也不进入moveToFailed流程。也就是说DelayedError只负责让 worker 走开真正停车的是moveToDelayed调用如果只抛异常而不调用moveToDelayed任务不会被推迟。这一语义在 python/tests/worker_test.py 中有专门的测试用例验证先moveToDelayed再raise DelayedError()。典型应用场景任务在运行中发现条件还不满足、几分钟后再试且希望保持锁的语义与重试次数不被浪费。3.1.1将maximumBlockTimeout委托给后端v3.1.1 的修复delegate maximumBlockTimeout to the backend (python)让阻塞超时上限变成后端专属属性。在抽象基类 backend.py 中maximumBlockTimeout默认返回 10 秒——这是 Redis 阻塞原语BZPOPMIN类操作的上限见 worker.py 中关于default_maximum_block_timeout的注释。而 postgres_backend.py 将其覆盖为 3600 秒理由写得很清楚PostgreSQL 的LISTEN/NOTIFY让连接保持打开并自动重新武装到下一个到期任务没有 Redis 那种为廉价重连而限制 10s的需求更大的上限能让空闲 worker 真正安静下来而不是每 10 秒轮询一次——这对按空闲挂起的 serverless Postgres 尤其重要。此外还设置了minimumBlockTimeout与capabilities如canBlockFor1Ms、canDoubleTimeout等能力标记。worker 侧通过getattr(self.backend, maximumBlockTimeout, None)探测后端属性后端没有该属性时回退到默认值见 worker.py 与 python/tests/worker_disconnect_test.py 中后端缺失该属性时回退为 10的测试。3.2.0Queue.getDeduplicationJobIdv3.2.0 为Queue新增getDeduplicationJobId方法用于根据去重标识反查任务 ID。调用方式job_id await queue.getDeduplicationJobId(my-dedup-id)高层实现位于 python/bullmq/queue.py它直接把请求转发给后端抽象return await self.backend.getDeduplicationJobId(id)。两个后端各自的实现Redis 后端对{keys[de]}:{id}做一次普通GET——de即 deduplication key 命名空间见 redis_backend.py注释明确说明这与 Node.js 客户端的Queue#getDeduplicationJobId对齐PostgreSQL 后端在 postgres_backend.py 中有对应实现其 SQL 语句见仓库的 PostgreSQL 命令目录如 python/bullmq/postgres/commands/get_deduplication_job_id.sql。配套测试在 python/tests/deduplication_test.py覆盖了缺失 ID返回空、任务完成后去重键被清理返回空、共享去重 ID 指向同一任务等多种场景。这个方法的实用价值在于任务因去重被跳过时调用方仍能拿到真正干活的那个任务的 ID用于查询状态或关联业务。其余修复与性能改进一览v3.0.5 失败原因存储worker 存储失败原因时不再做额外 JSON 编码——moveToFailedArgs中failedReason直接作为参数传给moveToFinished见 python/bullmq/scripts.py修复了失败原因被双重编码的问题对应 issue #4596。v3.0.6 速率限制处理 deferred failures 时不再计入速率限制窗口——失败任务的处理不再抢占限流配额这在重试风暴场景下能显著改善吞吐同步了 elixir/rust/dotnet 的行为。v3.2.3 去重键清理当任务键已不存在时删除残留的 deduplication key——修复了去重 ID 长期占用导致新任务被误判为重复的问题跨 python/elixir/php/rust/dotnet 同步。v3.0.1 发布完整性补全发布包中缺失的 SQL 文件影响 Python 与 Elixir 客户端确保 PostgreSQL 后端开箱即用。依赖维护v3.0.2 升级 redis 至 v7.4.1v3.2.1 升级 psycopg 至 v3.3.5v3.2.2 升级 semver 至 v3.1.0v3.2.4 ~ v3.2.6 批量更新 Python 依赖含 virtualenv v21.9.0。如何在仓库中跟进后续版本当前仓库的 Python 客户端实现位于 python/ 目录除 changelog 外还可参考顶层导出python/bullmq/init.py含DelayedError、WaitingChildrenError、UnrecoverableError等后端契约与实现python/bullmq/backend.py、python/bullmq/backends/高层类python/bullmq/queue.py、python/bullmq/worker.py、python/bullmq/job.py、python/bullmq/job_scheduler.py、python/bullmq/flow_producer.pyRedis Lua 脚本注册表python/bullmq/scripts.pyPostgreSQL SQL 命令python/bullmq/postgres/commands/测试python/tests/deduplication、delay、job scheduler、postgres backend、worker disconnect 等主题均有覆盖。如果使用 pip 安装可通过pip install bullmq获取发布版本仓库内的 python/pyproject.toml 与 python/setup.py 定义了包元数据与依赖。本文所有行为描述均以当前仓库源码与 changelog 为准升级前请以你实际安装的版本对应的发布说明为准。赞分享后端消息队列任务调度【免费下载链接】bullmqBullMQ - Message Queue and Batch processing for NodeJS, Python, .NET, Elixir, Rust and PHP based on Redis or PostgreSQL项目地址https://gitcode.com/gh_mirrors/bu/bullmq点击查看免费下载相关推荐BullMQ Python 客户端 v3 演进解读可插拔后端架构、去重与延迟控制新能力全览BullMQ Python 客户端 v3 演进解读可插拔后端架构、去重与延迟控制新能力全览 导读本文以 python/CHANGELOG.md 为主体梳理后端消息队列任务调度Tcell v2 破坏性变更与新特性解析LazyGit 终端 UI 底座的演进Tcell v2 破坏性变更与新特性解析LazyGit 终端 UI 底座的演进 本文以 CHANGESv2.md https://link.gitcode.c开发工具CLI版本控制NetBox v3.6 版本全解析新特性、破坏性变更与 REST API 演进指南NetBox v3.6 版本全解析新特性、破坏性变更与 REST API 演进指南 NetBox v3.6 于 2023 年 8 月 30 日正式发布是 N后端网络数据建模上一篇TOML数据库配置终极指南简化数据库连接管理的完整教程 下一篇enzyme ReactWrapper 的 .length 属性统计包裹的 React 节点数量创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考