怎么用Python異步編程進(jìn)行API調(diào)用

本篇內(nèi)容主要講解“怎么用Python異步編程進(jìn)行API調(diào)用”，感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“怎么用Python異步編程進(jìn)行API調(diào)用”吧!

請(qǐng)求庫(kù)

通常，當(dāng)Python使用者希望進(jìn)行API調(diào)用時(shí)，他們會(huì)尋找請(qǐng)求庫(kù)。語(yǔ)法是我最喜歡的語(yǔ)法，因?yàn)槿绻蚁脒M(jìn)行API調(diào)用，則可以運(yùn)行：

import requests response = requests.get("http://example.com/") print(response)

現(xiàn)在，可以做一個(gè)for循環(huán)：

import requests for i in range(10):     response = requests.get("http://example.com/")     print(response)

每次我對(duì)進(jìn)行API調(diào)用時(shí)example.com，我都必須完成：

• 將請(qǐng)求發(fā)送至example.com。

• 等待回應(yīng)。

• 得到回應(yīng)。

如果想試圖獲取大量數(shù)據(jù)(例如，如果我想從Alpha Vantage API中提取fintech數(shù)據(jù))，您則需要一個(gè)可以設(shè)置的免費(fèi)密鑰api_key =  your_key_here。

import requests import os api_key = os.getenv('ALPHAVANTAGE_API_KEY') url = 'https://www.alphavantage.co/query?function=OVERVIEW&symbol={}&apikey={}' symbols = ['AAPL', 'GOOG', 'TSLA', 'MSFT', 'PEP'] results = [] for symbol in symbols:      response = requests.get(url.format(symbol, api_key))      results.append(response.json())

此時(shí)必須等待大約1.5秒才能進(jìn)行5個(gè)API調(diào)用，然后需要11秒才能進(jìn)行50個(gè)API調(diào)用，需要50秒才能進(jìn)行135個(gè)API調(diào)用……

如果您想獲得2,000家公司或1600萬(wàn)種顏色的數(shù)據(jù)，我們需要做一些擴(kuò)展。

異步代碼與同步代碼

當(dāng)我們運(yùn)行Python代碼時(shí)，我們的過(guò)程一行一行地讀取代碼。在執(zhí)行一行時(shí)，沒(méi)有其他代碼可以運(yùn)行。這就是所謂的同步代碼-依次進(jìn)行的所有操作。

在異步代碼中，我們可以在完成一項(xiàng)任務(wù)之前繼續(xù)執(zhí)行另一項(xiàng)任務(wù)。例如，如果我們考慮同步烹飪漢堡和蔬菜晚餐，我們的“代碼”將如下所示：

cook_burger（） cook_vegetables（）

在這種情況下，因?yàn)闈h堡是同步的，所以我們要等漢堡完成后才能開(kāi)始蔬菜。但我們并不總是希望等到漢堡做完之后才能開(kāi)始烹飪蔬菜。因此我們可以同時(shí)煮。一旦完成，我們就可以停止處理成品蔬菜或漢堡的任何工作。在異步代碼中，它看起來(lái)像這樣：

async def cook_meal():      await asyncio.gather(cook_burger(), cook_vegetables()) asyncio.run(cook_meal())

我們“收集”我們將要完成的任務(wù)，并await讓它們都完成。我們?cè)谑录h(huán)中運(yùn)行它們，以跟蹤完成后如何處理它們。您可以不斷檢查看看其中一個(gè)過(guò)程是否完成，從而想到事件循環(huán)。

現(xiàn)在您可能已經(jīng)聽(tīng)說(shuō)過(guò)多線(xiàn)程，并且它們是不同的，多線(xiàn)程用于擁有多個(gè)工作程序，而異步只有一名工人。

事件循環(huán)

回到我們的Alpha Vantage API調(diào)用示例?，F(xiàn)在，在我們的代碼中：

• 發(fā)出第一個(gè)請(qǐng)求。

• 等待。

• 得到第一反應(yīng)。

• 發(fā)出第二個(gè)請(qǐng)求。

• 等待。

• 得到第二個(gè)答復(fù)。

如果我們有五個(gè)符號(hào)，我們將“等待”五次。那么我們需要代替執(zhí)行此操作，啟動(dòng)一個(gè)API調(diào)用，然后啟動(dòng)其他API調(diào)用，最后再處理響應(yīng)。

另外，除了執(zhí)行上述操作之外，我們還可以：

• 發(fā)出第一個(gè)請(qǐng)求。

• 發(fā)出第二個(gè)請(qǐng)求。

• 等待。

• 得到第一反應(yīng)。

• 得到第二個(gè)答復(fù)。

在第二個(gè)示例中，我們只有一個(gè)等待時(shí)間!當(dāng)返回響應(yīng)時(shí)(可能在我們發(fā)出請(qǐng)求時(shí)發(fā)生)，因此我們需要一些處理返回的響應(yīng)的方法，這被稱(chēng)為事件循環(huán)。

事件循環(huán)會(huì)定期檢查以查看我們的異步操作是否已返回，并安排它們進(jìn)行相應(yīng)的處理。當(dāng)我們正常運(yùn)行Python時(shí)，沒(méi)有運(yùn)行任何事件循環(huán)來(lái)處理該事件，因此我們需要設(shè)置事件循環(huán)，以便可以按順序處理響應(yīng)。

然后，我們可以異步運(yùn)行我們的代碼。

輸入asyncio和aiohttp

我們現(xiàn)在知道，當(dāng)我們異步運(yùn)行代碼時(shí)，我們無(wú)須等待代碼操作完成，我們可以使用asyncio和aiohttp來(lái)進(jìn)行操作。

import asyncio import aiohttp import os import time api_key = os.getenv('ALPHAVANTAGE_API_KEY') url = 'https://www.alphavantage.co/query?function=OVERVIEW&symbol={}&apikey={}' symbols = ['AAPL', 'GOOG', 'TSLA', 'MSFT', 'PEP'] results = [] async def get_symbols():     async with aiohttp.ClientSession() as session:         for symbol in symbols:             response = await session.get(url.format(symbol, api_key), ssl=False) asyncio.run(get_symbols())

分解

我們將使用asyncio.run(get_symbols())，這會(huì)促使事件循環(huán)的啟動(dòng)，并且會(huì)允許我們使用異步代碼。

此時(shí)您會(huì)注意到，在以往許多的示例中，它們?nèi)绾螁?dòng)事件循環(huán)會(huì)更加明確：

loop = asyncio.get_event_loop() results = loop.run_until_complete(get_symbols()) loop.close()

此代碼塊的作用與asyncio.run(get_symbols())完全相同，那是我們的切入點(diǎn)。然后我們轉(zhuǎn)到函數(shù)：

async def get_symbols():     async with aiohttp.ClientSession() as session:         for symbol in symbols:             response = await session.get(url.format(symbol, api_key), ssl=False)

我們必須從async關(guān)鍵字開(kāi)始，這使Python知道此函數(shù)將是異步的，并且我們可以使用事件循環(huán)。

我們將展開(kāi)一個(gè)會(huì)話(huà)aiohttp，aiohttp是異步版本requests。

我們按照相同的方式進(jìn)行操作，并調(diào)用aiohttp版本的request.get(即session.get)，此處需要添加內(nèi)容ssl=False。

由于session.get是異步函數(shù)(也稱(chēng)為協(xié)程)，因此我們必須await做出響應(yīng)，否則它們會(huì)返回協(xié)程本身。

現(xiàn)在我們已經(jīng)請(qǐng)求代碼復(fù)制為異步語(yǔ)法，此時(shí)我們依然需要等待。

收集任務(wù)

我們即將要啟動(dòng)所有API調(diào)用。

import asyncio import aiohttp import os import time api_key = os.getenv('ALPHAVANTAGE_API_KEY') url = 'https://www.alphavantage.co/query?function=OVERVIEW&symbol={}&apikey={}' symbols = ['AAPL', 'GOOG', 'TSLA', 'MSFT', 'PEP'] results = [] def get_tasks(session):     tasks = []     for symbol in symbols:         tasks.append(session.get(url.format(symbol, api_key), ssl=False))     return tasks async def get_symbols():     async with aiohttp.ClientSession() as session:         tasks = get_tasks(session)         responses = await asyncio.gather(*tasks) asyncio.run(get_symbols())

我們有一個(gè)名為的全新功能get_tasks。此功能將所有協(xié)同程序合并到一個(gè)列表中，以便我們立即啟動(dòng)。請(qǐng)記住，此列表中的所有函數(shù)都必須是異步函數(shù)或已放置在事件隊(duì)列中的任務(wù)。

我們還可以通過(guò)以下方式獲得所有任務(wù)：

tasks = [session.get(URL.format(symbol, API_KEY), ssl=False) for symbol in symbols]

在得到要啟動(dòng)的功能/任務(wù)的列表后，我們可以get_symbols使用以下命令在功能中將它們?nèi)繂?dòng)：

responses = await asyncio.gather(*tasks)

我們將等待所有任務(wù)完成并將它們放入responses對(duì)象中。

responses = await asyncio.gather(session.get(URL.format('IBM', API_KEY), ssl=False), session.get(URL.format('AAPL', API_KEY), ssl=False), session.get(URL.format('MSFT', API_KEY), ssl=False))

因?yàn)?tasks只是將列表解引用為變量的一種方法。

我們“收集”所有任務(wù)并將其運(yùn)送出去，當(dāng)它們響應(yīng)時(shí)，事件循環(huán)將它們拾取，并在我們交付所有任務(wù)后將它們放入要處理的隊(duì)列中。

協(xié)程與任務(wù)

在上面的示例中，我們向asyncio.gather函數(shù)傳遞了異步協(xié)程列表，以便可以將它們調(diào)度到事件循環(huán)中，實(shí)際上可以更快地將它們調(diào)度到事件循環(huán)中!

在我們的get_tasks函數(shù)中，我們調(diào)用了：

tasks.append(session.get(url.format(symbol, api_key), ssl=False))

我們將該session.get函數(shù)添加到了任務(wù)列表中，并且僅在調(diào)用時(shí)將它們添加到了事件循環(huán)中g(shù)ather。實(shí)際上，您可以使用asyncio.create_task以下命令更快地將其添加到事件循環(huán)中：

tasks.append(asyncio.create_task(session.get(url.format(symbol, api_key), ssl=False)))

這會(huì)將session.get函數(shù)添加到事件循環(huán)中，并且asyncio.gather函數(shù)將等待該任務(wù)完成。

請(qǐng)記住它們的不同之處。協(xié)程是函數(shù)，而任務(wù)則是在事件循環(huán)中安排的任務(wù)。asyncio.gather將等待任務(wù)返回和/或?qū)f(xié)程安排到事件循環(huán)中，并等待它們返回。

到此，相信大家對(duì)“怎么用Python異步編程進(jìn)行API調(diào)用”有了更深的了解，不妨來(lái)實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢(xún)，關(guān)注我們，繼續(xù)學(xué)習(xí)！