Python批量删除mysql中千万级大量数据的脚本分享
场景描述
线上mysql数据库里面有张表保存有每天的统计结果,每天有1千多万条,这是我们意想不到的,统计结果咋有这么多。运维找过来,磁盘占了200G,最后问了运营,可以只保留最近3天的,前面的数据,只能删了。删,怎么删?
因为这是线上数据库,里面存放有很多其它数据表,如果直接删除这张表的数据,肯定不行,可能会对其它表有影响。尝试每次只删除一天的数据,还是卡顿的厉害,没办法,写个Python脚本批量删除吧。
具体思路是:
- 每次只删除一天的数据;
- 删除一天的数据,每次删除50000条;
- 一天的数据删除完,开始删除下一天的数据;
Python代码
#-*-coding:utf-8-*-
importsys
#这是我们内部封装的PythonModule
sys.path.append('/var/lib/hadoop-hdfs/scripts/python_module2')
importkeguang.commonsascommons
importkeguang.timedefastimedef
importkeguang.sql.mysqlclientasmysql
defrun(starttime,endtime,regx):
tb_name='statistic_ad_image_final_count'
days=timedef.getDays(starttime,endtime,regx)
#遍历删除所有天的数据
fordayindays:
print'%s数据删除开始'%(day)
mclient=getConn()
sql='''
select1from%swheredate='%s'limit1
'''%(tb_name,day)
printsql
result=mclient.query(sql)
#如果查询到了这一天的数据,继续删除
whileresultisnot():
sql='deletefrom%swheredate="%s"limit50000'%(tb_name,day)
printsql
mclient.execute(sql)
sql='''
select1from%swheredate='%s'limit1
'''%(tb_name,day)
printsql
result=mclient.query(sql)
print'%s数据删除完成'%(day)
mclient.close()
#返回mysql连接
defgetConn():
returnmysql.MysqlClient(host='0.0.0.0',user='test',passwd='test',db='statistic')
if__name__=='__main__':
regx='%Y-%m-%d'
yesday=timedef.getYes(regx,-1)
starttime='2019-08-17'
endtime='2019-08-30'
run(starttime,endtime,regx)
以上就是Python批量删除mysql中千万级大量数据的脚本的详细内容,更多关于python删除MySQL数据的资料请关注毛票票其它相关文章!