0

0

Python 定时任务的幂等性保障

舞姬之光

舞姬之光

发布时间:2026-02-17 14:21:16

|

999人浏览过

|

来源于php中文网

原创

schedule库本身不解决幂等性,因其仅负责定时入队和调用函数,不记录状态、无锁机制、不支持外部协调;需自行通过数据库唯一约束、redis分布式锁等方式实现。

python 定时任务的幂等性保障

为什么 schedule 库本身不解决幂等性

因为 schedule 只是把函数塞进队列、按时调用,它不管这个函数执行了几次、有没有成功、会不会重复写数据库。你写个 send_email(user_id),它就真的一次又一次调用——哪怕上次还没发完,或者网络超时导致发了两遍。

常见错误现象:schedule.every(10).minutes.do(send_notification) 在进程重启后没做去重,结果同一通知发了三轮;或者服务部署多实例,每个实例都跑一套 schedule,通知直接翻倍。

  • 它不记录执行状态,也不检查上一次是否完成
  • 没有内置锁、没有任务 ID、不支持外部存储协调
  • 所有“只运行一次”的逻辑,必须你自己加

用数据库唯一约束 + INSERT ... ON CONFLICT 挡住重复

这是最轻量、最可控的方式:把每次要执行的任务抽象成一条带时间戳和业务键的记录,先尝试插入,只在插入成功时才真正干活。

使用场景:发短信、更新用户积分、生成日账单这类不能重复的核心操作。

立即学习Python免费学习笔记(深入)”;

示例(PostgreSQL):

INSERT INTO task_run_log (task_name, run_at, status) 
VALUES ('daily_report', '2024-06-15 02:00:00', 'pending') 
ON CONFLICT (task_name, DATE(run_at)) DO NOTHING;

如果这条 SQL 返回影响行数为 0,说明当天这个任务已存在,跳过执行;为 1,则继续走后续逻辑。

V5Shop联盟系统
V5Shop联盟系统

V5SHOP联盟系统是一款基于电子商务平台和B2C网店系统开发的嵌入式联盟系统,能够快捷的进行代理商管理,销售提成管理。 功能介绍: API接口:最新的V5SHOP联盟系统V2.0程序,已经添加内置API接口,能够支持和任意网店系统、社区系统的整合。 SOURCE值自定义:轻松设置联盟系统SOURCE值在客户端保留时间,让联盟运营更加随心应手。 会员等级提成自定义:按照代理成交销

下载
  • 关键参数是 task_name 和日期粒度的组合,不是单纯用 UUID
  • MySQL 用户用 INSERT IGNOREREPLACE INTO,但注意后者会触发 DELETE+INSERT,可能影响自增 ID 或触发器
  • 别依赖 Python 层的 if not executed_today: 判断——多进程下必然竞争

APSchedulercoalesce=True 不等于幂等

它只保证“漏掉的调度只执行一次”,比如服务停了 3 小时,原本该跑 18 次的任务,恢复后只跑 1 次。但它不防并发、不防重入、不防多实例。

容易踩的坑:

  • coalesce=TrueIntervalTrigger(minutes=1) 有效,但对 CronTrigger(hour='2') 基本无效——cron 类型默认就只按计划点触发一次
  • 如果你用 BackgroundScheduler + 多个 worker 进程,每个进程都起一个 APScheduler,coalesce 在各自进程内生效,全局照样重复
  • 它不阻止函数内部重复写 DB 或发消息,只是少调用几次函数而已

用 Redis 分布式锁做临界区控制

适合需要严格串行、且能接受短暂延迟的场景,比如库存扣减、支付对账。

核心逻辑:执行前先 SET key value EX 300 NX,拿到锁才继续;结束后 DEL(注意用 Lua 脚本防误删)。

性能影响明显:每次任务多一次 Redis 往返;锁过期时间必须大于任务最大耗时,否则可能被其他实例续上并行执行。

  • 别用 redis-pylock.acquire() 默认行为——它会阻塞等待,而定时任务不该卡住整个调度线程
  • 推荐用 try_lock = redis.set(key, 'running', ex=300, nx=True),返回 True 再干活,否则直接 return
  • Redis 故障时锁失效,得配合数据库唯一约束兜底,不能只靠 Redis

复杂点在于锁生命周期和任务实际耗时的匹配,还有跨实例间时钟漂移——这些细节一旦忽略,表面看没问题,压测或上线后才暴露重复。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
数据分析工具有哪些
数据分析工具有哪些

数据分析工具有Excel、SQL、Python、R、Tableau、Power BI、SAS、SPSS和MATLAB等。详细介绍:1、Excel,具有强大的计算和数据处理功能;2、SQL,可以进行数据查询、过滤、排序、聚合等操作;3、Python,拥有丰富的数据分析库;4、R,拥有丰富的统计分析库和图形库;5、Tableau,提供了直观易用的用户界面等等。

965

2023.10.12

SQL中distinct的用法
SQL中distinct的用法

SQL中distinct的语法是“SELECT DISTINCT column1, column2,...,FROM table_name;”。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

334

2023.10.27

SQL中months_between使用方法
SQL中months_between使用方法

在SQL中,MONTHS_BETWEEN 是一个常见的函数,用于计算两个日期之间的月份差。想了解更多SQL的相关内容,可以阅读本专题下面的文章。

376

2024.02.23

SQL出现5120错误解决方法
SQL出现5120错误解决方法

SQL Server错误5120是由于没有足够的权限来访问或操作指定的数据库或文件引起的。想了解更多sql错误的相关内容,可以阅读本专题下面的文章。

1696

2024.03.06

sql procedure语法错误解决方法
sql procedure语法错误解决方法

sql procedure语法错误解决办法:1、仔细检查错误消息;2、检查语法规则;3、检查括号和引号;4、检查变量和参数;5、检查关键字和函数;6、逐步调试;7、参考文档和示例。想了解更多语法错误的相关内容,可以阅读本专题下面的文章。

370

2024.03.06

oracle数据库运行sql方法
oracle数据库运行sql方法

运行sql步骤包括:打开sql plus工具并连接到数据库。在提示符下输入sql语句。按enter键运行该语句。查看结果,错误消息或退出sql plus。想了解更多oracle数据库的相关内容,可以阅读本专题下面的文章。

1252

2024.04.07

sql中where的含义
sql中where的含义

sql中where子句用于从表中过滤数据,它基于指定条件选择特定的行。想了解更多where的相关内容,可以阅读本专题下面的文章。

585

2024.04.29

sql中删除表的语句是什么
sql中删除表的语句是什么

sql中用于删除表的语句是drop table。语法为drop table table_name;该语句将永久删除指定表的表和数据。想了解更多sql的相关内容,可以阅读本专题下面的文章。

436

2024.04.29

pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法
pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法

本专题系统整理pixiv网页版官网入口及登录访问方式,涵盖官网登录页面直达路径、在线阅读入口及快速进入方法说明,帮助用户高效找到pixiv官方网站,实现便捷、安全的网页端浏览与账号登录体验。

283

2026.02.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 22.4万人学习

Django 教程
Django 教程

共28课时 | 4.3万人学习

SciPy 教程
SciPy 教程

共10课时 | 1.6万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号