async for 是 Python 異步編程中用于遍歷異步可迭代對(duì)象的特性，必須在 async def 函數(shù)中使用。1. 它依賴于 aiter 和 anext 兩個(gè)異步方法，其中 aiter 返回異步迭代器本身，__anext__ 返回 awaitable 的值并需拋出 StopAsyncIteration 以結(jié)束循環(huán)；2. 常用于處理異步數(shù)據(jù)流，如網(wǎng)絡(luò)請(qǐng)求、數(shù)據(jù)庫(kù)查詢等場(chǎng)景，例如使用 aiohttp 流式讀取 HTTP 響應(yīng)內(nèi)容或通過 asyncpg 逐條獲取數(shù)據(jù)庫(kù)記錄；3. 也可結(jié)合 async yield 實(shí)現(xiàn)異步生成器，如異步計(jì)數(shù)器；4. 使用時(shí)需注意正確實(shí)現(xiàn)異常處理，避免死循環(huán)，并區(qū)分其與普通 for 的不同應(yīng)用場(chǎng)景。

Python 的 async for 是異步編程中一個(gè)很有用的特性，主要用于遍歷異步可迭代對(duì)象。它通常配合 async def __aiter__ 和 async def __anext__ 方法一起使用，是處理異步數(shù)據(jù)流的一種方式。

什么是異步迭代？

在 Python 中，普通循環(huán) for 可以用來(lái)遍歷實(shí)現(xiàn)了 __iter__ 和 __next__ 方法的對(duì)象。而異步迭代則是類似的概念，但適用于異步場(chǎng)景，比如從網(wǎng)絡(luò)讀取數(shù)據(jù)、從數(shù)據(jù)庫(kù)分批次獲取記錄等。

異步迭代器有兩個(gè)關(guān)鍵方法：

• __aiter__：返回一個(gè)異步迭代器。
• __anext__：返回下一個(gè) awaitable 的值。

這些方法必須用 async def 定義，這樣才能在 async for 循環(huán)中被調(diào)用。

async for 的基本用法

假設(shè)你有一個(gè)異步的數(shù)據(jù)源，比如從網(wǎng)絡(luò)上逐條接收消息，你可以這樣寫：

class AsyncMessageStream:
    def __init__(self, messages):
        self.messages = messages
        self.index = 0

    def __aiter__(self):
        return self

    async def __anext__(self):
        if self.index >= len(self.messages):
            raise StopAsyncIteration
        message = self.messages[self.index]
        self.index  = 1
        await asyncio.sleep(0.1)  # 模擬異步操作
        return message

然后使用 async for 來(lái)遍歷這個(gè)流：

async def read_messages():
    async for msg in AsyncMessageStream(["hello", "world"]):
        print(msg)

這段代碼會(huì)依次打印出 "hello" 和 "world"，中間每次都會(huì)等待一小段時(shí)間。

常見應(yīng)用場(chǎng)景

1. 異步讀取文件或網(wǎng)絡(luò)數(shù)據(jù) 當(dāng)你需要一行行讀取一個(gè)大文件或者從 WebSocket 接收多條消息時(shí)，可以用 async for 實(shí)現(xiàn)非阻塞的逐條處理。

例如使用 aiohttp 獲取 HTTP 流式響應(yīng)內(nèi)容：

async with session.get('http://example.com/stream') as resp:
    async for line in resp.content:
        process(line)

2. 數(shù)據(jù)庫(kù)查詢結(jié)果流式處理 一些異步數(shù)據(jù)庫(kù)驅(qū)動(dòng)（如 asyncpg 或 motor）支持逐條獲取查詢結(jié)果，而不是一次性加載所有數(shù)據(jù)。

3. 自定義異步生成器 除了類的方式，還可以使用 async def yield 構(gòu)建異步生成器：

async def async_counter(limit):
    for i in range(limit):
        await asyncio.sleep(0.1)
        yield i

然后像這樣使用：

async for number in async_counter(5):
    print(number)

使用注意事項(xiàng)

• async for 必須在 async def 函數(shù)中使用。
• 如果你在自定義類中實(shí)現(xiàn)異步迭代，請(qǐng)確保正確拋出 StopAsyncIteration，否則可能陷入死循環(huán)。
• 不要把 async for 和普通的 for 混淆，它們處理的是不同類型的迭代器。
• 異步迭代器中的 __anext__ 方法必須是協(xié)程函數(shù)（即 async def 定義的函數(shù)）。

基本上就這些。理解了異步迭代器和 async for 的關(guān)系后，你會(huì)發(fā)現(xiàn)它其實(shí)并不復(fù)雜，只是容易忽略了一些細(xì)節(jié)，比如接口的定義和異常的處理。

以上是python async解釋了的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！