首页
学习
活动
专区
圈层
工具
发布

Python 基于Python从mysql表读取千万数据实践

场景: 有以下两个表,两者都有一个表字段,名为waybill_no,我们需要从tl_waybill_bar_record表读取1000w条唯一的waybill_no,然后作为INSERT SQL语句的一部分...有部分重复 实现思路 思路1、利用MySql的LIMIT offset, length分页功能+ORDER BY primary_key按主键排序,循环读取数据,然后解析读取的数据,直到满足条件停止...% min_seq_id result = test_platform_db.select_many_record(query) ……(后续处理) 问题 跑程序的时候,经常会突然“卡死”,可能是Python...类库自身原因,也可能是数据库请求过于频繁,这样会导致获取的结果丢失,需要重头开始跑 解决方法: 一边跑,一边写入本地文件,同时输出上次读取的记录的位置(思路2来说,就是那个最小主键值),然后重新跑程序时.../result/waybill_no.txt', 'r+', encoding='utf-8') waybill_no_set = set() # 用于存储获取的waybill_no # 读取上次获取的数据

3.1K10
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    【python 3.6】python读取json数据存入MySQL(二)

    在网上找到一个包含全国各省市经纬度的json文件,也可以通过上次的办法,解析json关键字,构造SQL语句,插入数据库。...考虑到json中每个省有经纬度,同时嵌套了省内城市的经纬度,因此这里计划在数据库中创建如下表结构: 【省名】【经度】【维度】【市名】【经度】【维度】 所以,需要将json中的内容整合拼接一下,输出一个list...下面是代码: #python 3.6 # -*- coding:utf-8 -*- __author__ = 'BH8ANK' import json import pymysql conn = pymysql.connect...( host='localhost', # mysql服务器地址 port=3306, # 端口号 user='root', # 用户名 passwd='xxxxx...', # 密码 db='xdb', # 数据库名称 charset='utf8', # 连接编码,根据需要填写 ) cur = conn.cursor() # 创建并返回游标

    3.2K10

    Python读取Excel存入MySQL

    连接数据库TESTDB使用的用户名为 "testuser" ,密码为 "test123",你可以可以自己设定或者直接使用root用户名及其密码,Mysql数据库用户授权请使用Grant命令。...在你的机子上已经安装了 Python MySQLdb 模块。 如果您对sql语句不熟悉,可以访问我们的 SQL基础教程 实例: 以下实例链接Mysql的TESTDB数据库: #!...Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。...持续性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。...---- 错误处理 DB API中定义了一些数据库操作的错误及异常,下表列出了这些错误和异常: 异常 描述 Warning 当有严重警告时触发,例如插入数据是被截断等等。

    4.1K10

    python 读取 mysql 中文乱码

    这两天看了很多关于mysql中文乱码的问题,除了创建table的时候设置为utf8编码以及修改mysql配置文件的方法外,很少有人提关于python库中中文乱码的处理办法,尤其是records库的中文乱码问题...文中的代码在CentOS或者Ubuntu操作系统python3的环境下都测试没问题。...基于python3使用pymysql来读取mysql中的内容,在connect中一定要加入charset参数,否则中文在ubuntu或者centos下读出来显示一堆问号。...cursor.fetchall(): print(row) db.close() records库是requests作者 kennethreitz 写的一个非常方便的针对各种数据库进行数据处理的...python库,只不过文档和网上的相关内容很少,尤其是中文的情况,如果不知道正确的使用方法很容易出现乱码。

    7.2K20

    MySQL单表有10亿数据如何做迁移

    MySQL单表有10亿数据如何做迁移整体思路是先全量后增量,双写兜底,灰度切换,可回滚迁移核心三原则(面试官最看重的底线)✅ 数据零丢失:所有变更必须可追溯,最终一致性保证 ✅ 最小停机时间:业务无感知或秒级停机...⭐⭐⭐⭐⭐ Canal MySQL 增量同步 阿里开源、成熟稳定、低延迟 仅支持 MySQL ⭐⭐⭐⭐⭐ Debezium 多数据源 CDC 生态好、支持 Kafka 部署复杂...提前修改binlog_format=ROW,重启 MySQL 生效 大字段导致单条记录过大 迁移速度骤降、OOM 大字段单独拆表,或迁移时过滤非必要历史数据 主键不连续导致数据倾斜...真实现场模拟面试真实面试对话场景面试官 ‍:“咱们有个 MySQL 单表,线上数据马上就要到 10 亿了,现在打算把它迁到一个新实例,或者换成新表结构。要求不能长时间停服,也不能把线上业务拖垮。...按索引分段多线程并行,BETWEEN 走主键,游标式读取 pt-archiver、自定义Java线程池、LIMIT 控制无合适切分键 表没有自增ID或时间索引 评估阶段必须加字段

    33110

    mysql数据恢复案例003 -- 有坏块的表怎么解析?

    导读前两天遇到一个mysql坏块恢复场景, 简单记录一下.恢复报错&分析数据文件是5.7环境的, 现在ibd2sql不再需要转换到8.0环境即可解析....,无法获取到REAL_SIZE,PAGENO, 因为_ndata38:46并没有8字节, 也就是读取溢出页的时候就已经有问题了, 也就是说溢出页的PAGENO解析就已经出错了...., 表结构信息有问题的概率很低, 那更可能的就是存在坏块....root_page中的index_id(即为主键的index id), 从头开始读取数据文件PAGE(读取的时候会判断页类型(这种做法并不好),但是有坏块的话, 页数据类型可能就有问题,导致一些意料之外的错误...于是我们修改--force的功能为: 跳过坏块一页页解析主键索引上的数据.然后我们再次测试验证下(加上--force):python3 main.py xxxxxxx.ibd --sql --force

    67230
    领券