脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 脚本专栏 → python → aioysql异步操作MySQL python

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

 更新时间：2019年04月11日 14:23:13   作者：Devil-  
这篇文章主要介绍了aioysql(异步操作MySQL)-python 的相关知识，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下

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

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

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：最重要的是获得连接：

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

2.  aiomysql — API Reference

connection

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

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 游标

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，希望对大家有所帮助，如果大家有任何疑问欢迎给我留言，小编会及时回复大家的！

您可能感兴趣的文章:

相关文章

  • Python集合的基础操作

    Python集合的基础操作

    这篇文章主要介绍了Python集合的基础操作，Python中的集合和数学上的集合基本是没有区别的，是无序的，即不可以使用索引访问的，集合中是不能出现重复元素的。想着情了解具体内容的小伙伴可以参考下面文章内容
    2021-11-11
  • python脚本第一行如何写

    python脚本第一行如何写

    在本篇内容里小编给大家整理的是一篇关于python脚本第一行如何写相关文章，有需要的朋友们可以参考下。
    2020-08-08
  • Python用yield from实现异步协程爬虫的实践

    Python用yield from实现异步协程爬虫的实践

    本文主要介绍了Python用yield from实现异步协程爬虫的实践，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2023-01-01
  • python查看矩阵的行列号以及维数方式

    python查看矩阵的行列号以及维数方式

    这篇文章主要介绍了python查看矩阵的行列号以及维数方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-05-05
  • Matplotlib控制坐标轴刻度间距与标签实例代码

    Matplotlib控制坐标轴刻度间距与标签实例代码

    在matplotlib中,记号是图形两个轴上的小标记,到目前为止,我们让matplotlib处理轴图例上记号的位置,下面这篇文章主要给大家介绍了关于Matplotlib控制坐标轴刻度间距与标签的相关资料,需要的朋友可以参考下
    2021-10-10
  • python飞机大战游戏实例讲解

    python飞机大战游戏实例讲解

    在本篇文章里小编给大家整理的是一篇关于python飞机大战游戏实例讲解，有兴趣的朋友们可以参考下。
    2020-12-12
  • 如何使用Cython对python代码进行加密

    如何使用Cython对python代码进行加密

    这篇文章主要介绍了如何使用Cython对python代码进行加密,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07
  • Python实现简单字典树的方法

    Python实现简单字典树的方法

    这篇文章主要介绍了Python实现简单字典树的方法,实例分析了Python字典树的定义、实现与使用技巧,需要的朋友可以参考下
    2016-04-04
  • Python运算符重载用法实例

    Python运算符重载用法实例

    这篇文章主要介绍了Python运算符重载用法,实例分析了Python运算符重载实现加法运算的技巧,需要的朋友可以参考下
    2015-05-05
  • Python变量和数据类型详解

    Python变量和数据类型详解

    这篇文章主要介绍了Python变量和数据类型,是Python学习当中的基础知识,需要的朋友可以参考下,希望能够给你带来帮助
    2021-10-10

最新评论