[鱼刺-Python-1] asyncio 非同步呼叫POST Method方法

Python非同步需要使用到asyncio，简单测试如下

import asyncio
import requests
import json
import time
from datetime import datetime

async def syncHello(delay):
    print("Hello:",delay)
    await asyncio.sleep(delay)
    print("Bye:",delay)

if __name__ == "__main__":

    ts = [
		5,3,1
    ]
    
    now = lambda: time.time()
    start = now()
    tasks = [syncHello(i) for i in ts]
    asyncio.run(asyncio.wait(tasks))
    print('Total TIME:', now() - start)

代码执行後，在await时，就会转去执行其他task，然而实务上你直接用改成API呼叫是不会work的，因为呼叫API并没有使用到await，以至於没有效果(会卡住等待Response)，所以这时候就要再多使用 loop.run_in_executor，让呼叫API时在等待Response时，转去继续执行其他task

话不多说，上代码!
方法如下:

import asyncio
import requests
import json
import time
import uuid
from datetime import datetime

loop = asyncio.get_event_loop()

async def doBuyBook(bookName):

		logkey = uuid.uuid4().hex[:6]
		print(f"[{logkey}] doBuyBook.start ==> {bookName}")
		
		req = {
			"BookName": bookName
		}
		
		#非同步执行
		r = await loop.run_in_executor(None, 
			lambda: requests.post("http://127.0.0.1:8321/bookstore/buybook", json = req))
		
		response_data = json.loads(r.text)
		print(f"[{logkey}] response_data:{response_data}")
		print(f"[{logkey}] doBuyBook.end")

if __name__ == "__main__":
    
    bookNames = [
		"PYTHON_DEV",
		"JAVA_DEV",
		"GOLANG_DEV",
		"C#_DEV"
    ]
    
    now = lambda: time.time()
    start = now()
    
    tasks = [loop.create_task(doBuyBook(i)) for i in bookNames]
    loop.run_until_complete(asyncio.wait(tasks))
    
    print('Total TIME: ', now() - start)

使用 get_event_loop 建立回圈事件 loop，使用 run_in_executor 把呼叫API POST丢入线程池中执行，在await时，就会转去执行下一个task，当API回应时间较慢时，会明显看到打印出来的LOG，会先全部打印出，然後才会依序打印出API的Response

大概就是这样，Cheer!! 测试用的API如何建立写在下一篇