怎么分析pymysql非线程安全导致的故障

今天就跟大家聊聊有关怎么分析pymysql非线程安全导致的故障,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。

mysqldb   这个python 驱动只支持到 python 2 . 

转到python 3 后.   无法使用了.  

启用  pymysql 这个驱动. 

在投入生产后, 发现了一些问题. 

在使用较大规模的 for id  in  [list]:

   db.query (xxxxxxxxx)   

查询数据库的时候,  出现了一些比较奇怪的网络连接层面的报错. 

数据报 的 头字节 格式错误. 

如果只是执行单个查询则是不会报错. 

经过排查,  发现这是pymysql 的bug 或者缺陷. 

即 PYmysql 不是线程安全的.   由于我们自己的组件  dba模块. 

对数据库查询做了包装.  

导致 在某些情况情况下.   python 的代码优化模块. 

对代码的优化, 出现了并行的情况. 

即前一个sql 查询没有返回的情况下,  另一个线程启动了并从同一个数据库句柄读取数据. 

导致了 数据报的格式错误. 

改进方案: 

1.  对数据库的连接 增加线程锁.  

     每一次查询 都加锁.   在异常处理中也要同时加上解锁代码. 

2. 更换为mysql.com 提供的 官方的  mysql-connector-python  驱动.  目前没有发现问题. 

看完上述内容,你们对怎么分析pymysql非线程安全导致的故障有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注蜗牛博客行业资讯频道,感谢大家的支持。

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:niceseo99@gmail.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

评论

有免费节点资源,我们会通知你!加入纸飞机订阅群

×
天气预报查看日历分享网页手机扫码留言评论Telegram