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',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',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，希望對大家有所幫助，如果大家有任何疑問歡迎給我留言，小編會及時回覆大家的！