个人中心
gpt4 book ai didi

python中aioysql(异步操作MySQL)的方法

转载 作者：qq735679552 更新时间：2022-09-28 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章python中aioysql(异步操作MySQL)的方法由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

python异步io初探 。

探索异步io执之前，先说说io的种类 。

1.阻塞io最简单，即读写数据时，需要等待操作完成，才能继续执行。进阶的做法就是用多线程来处理需要io的部分，缺点是开销会有些大.

2.非阻塞io，即读写数据时，如果暂时不可读写，则立刻返回，而不等待。因为不知道什么时候是可读写的，所以轮询时可能会浪费cpu时间.

3.io复用，即在读写数据前，先检查哪些描述符是可读写的，再去读写。select 和 poll 就是这样做的，它们会遍历所有被监视的描述符，查看是否满足，这个检查的过程是阻塞的。而 epoll、kqueue 和/dev/poll 则做了些改进，事先注册需要检查哪些描述符的哪些事件，当状态发生变化时，内核会调用对应的回调函数，将这些描述符保存下来；下次获取可用的描述符时，直接返回这些发生变化的描述符即可.

4.信号驱动，即描述符就绪时，内核发送sigio信号，再由信号处理程序处理这些信号即可。不过信号处理的时机是从内核态返回用户态时，感觉也得把这些事件收集起来才好处理，有点想模拟io复用了.

5.最后时异步io,即读写数据时，只注册事件，内核完成读写后（读取的数据会复制到用户态），再调用事件处理函数。这整个过程都不会阻塞调用线程.

python 3.4 开始，标准库里又新增了 asyncio 这个模块.

从原理上来说，它和 tornado 其实差不多，都是注册 io 事件，然后在 io loop 中等待事件发生，然后调用相应的处理函数.

aiomysql说明 。

1. poll 。

此库提供一个简单的连接对象用法:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import asyncio
import aiomysql
loop = asyncio.get_event_loop()
@asyncio .coroutine
def go()
  pool = yield from aiomysql.create_pool(host = '127.0.0.1' , port = 3306 ,
            user = 'root' , password = '',
            db = 'mysql' , loop = loop)
  with ( yield from pool) as conn:
   cur = yield from conn.cursor()
   yield from cur.execute( "select 10" )
   # print(cur.description)
   (r,) = yield from cur.fetchone()
   assert r = = 10
  pool.close()
  yield from pool.wait_closed()
loop.run_until_complete(go())

解释:

create_pool(minsize=1, maxsize=10, loop=none, **kwargs) 。

一个协程，创建连接池，连接database 。

参数:

minsize(int)最小的池子 ， 反之maxsize(int) loop一个可选的事件循环实例，若未循环，使用 asyncio.get_event_loop() echo(bool)默认log执行sql查询 kwargs class pool：最重要的是获得连接:

?
1
2
with ( yield from pool) as conn:
  cur = yield from conn.cursor()

2.  aiomysql — api reference 。

connection 。

该库用来连接mysql,使用简单的aiomysql.connect(),可以连接一个数据库或者关联池子以连接更多 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
import asyncio # 举例说明
import aiomysql
loop = asyncio.get_event_loop()
@asyncio .coroutine
def test_example():
  conn = yield from aiomysql.connect(host = '127.0.0.1' , port = 3306 ,
           user = 'root' , password = ' ', db=' mysql',
           loop = loop)
  cur = yield from conn.cursor()
  yield from cur.execute( "select host,user from user" )
  print (cur.description)
  r = yield from cur.fetchall()
  print (r)
  yield from cur.close()
  conn.close()
loop.run_until_complete(test_example())

3. cursors 游标 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
import asyncio
import aiomysql
loop = asyncio.get_event_loop()
@asyncio .coroutine
def test_example():
  conn = yield from aiomysql.connect(host = '127.0.0.1' , port = 3306 ,
           user = 'root' , password = '',
           db = 'mysql' , loop = loop)
  # create default cursor
  cursor = yield from conn.cursor()
  # execute sql query # 执行sql查询
  yield from cursor.execute( "select host, user from user" )
  # fetch all results
  r = yield from cursor.fetchall()
  # detach cursor from connection
  yield from cursor.close()
  # close connection
  conn.close()
loop.run_until_complete(test_example())

总结 。

以上所述是小编给大家介绍的aioysql(异步操作mysql)-python，希望对大家有所帮助，如果大家有任何疑问欢迎给我留言，小编会及时回复大家的！ 。

原文链接：https://www.cnblogs.com/devils19/archive/2019/04/11/10689025.html 。

最后此篇关于python中aioysql(异步操作MySQL)的方法的文章就讲到这里了,如果你想了解更多关于python中aioysql(异步操作MySQL)的方法的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

25 4 0
文章推荐： 详解python执行shell脚本创建用户及相关操作
文章推荐： Next.js 强劲对手来了！ Remix 正式宣布开源
文章推荐： 前端进阶: 如何用 Javascript 存储函数?
文章推荐： 很酷的python表白工具 你喜欢我吗
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com