python-asyncio

3熱度

1回答

我正在閱讀asyncio程序包中Protocol和Transport類的文檔。具體來說：當繼承協議類時，建議您重寫某些方法。這些方法是回調函數：它們將在某些事件中由傳輸器調用（例如，在收到某些數據時）。除非您正在實施交通工具，否則您不應該自己撥打電話，。着重強調因此，在原則上，它應該是可以實現的傳輸，但是...... 傳輸是通過ASYNCIO以各種抽象類提供各種溝通渠道。你通常不會自己實例化

3熱度

1回答

如何在python run_in_executor方法調用中捕獲異常

如何在run_in_executor調用的run_long_thing（）函數中引發異常？它看起來像被吞嚥。我不需要阻塞代碼中的函數結果。它基本上是一個射後不理功能，但我仍然需要捕獲異常，如果有任何... import asyncio import time def fire_and_forget(task, *args, **kwargs): loop = asyncio.g

1熱度

1回答

什麼是異步迭代器的類型？

例（以下問題）：？？ import asyncio import typing as t from aiokafka import AIOKafkaConsumer class KafkaSimpleClient: ... async def receive(self, topic: str) -> ???: bootstrap_servers =

0熱度

1回答

爲什麼StreamReader.readexactly（）會導致套接字錯誤，但不會導致StreamReader.read（）？

我正在使用Asyncio進行網絡編程，在python中編寫應用程序。我有類似的代碼太： try: data = await self._reader.readexactly(10000) # Code that uses data except IncompleteReadError as e: data = e.parial # More code

1熱度

1回答

python 3.6和ValueError：循環參數必須與未來

一致我只想運行一個簡單的測試示例，但我得到下面的錯誤。我該如何解決？ import asyncio import uvloop import concurrent.futures import time asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) async def do_some_work(x): whi

1熱度

1回答

使用Python ASYNCIO等待GPIO中斷

我想程序從龍捲風轉換爲ASYNCIO的第一步是使用實際ASYNCIO事件循環作爲described here。此應用程序在嵌入式Linux機器上運行，我使用通過sysfs/gpio subsystem的GPIO以及我正在等待中斷的某些GPIO。我能直接在此整合到龍捲風IOLoop做： # Register with the queue self.io_loop.add_handler(

1熱度

1回答

RuntimeError：這個事件循環已經在Python中運行了

我想我得到這個錯誤是因爲我的代碼調用asyncio.get_event_loop().run_until_complete(foo())兩次。一旦從foo()第二次從函數調用foo()。那麼我的問題是：爲什麼這會成爲一個問題呢？爲什麼我更關心這個循環是否正在運行？有這個問題，我認爲它，做編輯，遮蔽它（有些人喜歡遵守規則不理解他們，從而從標題刪除「非法」二字）。不幸的是，這造成了混亂。我對提出錯

-2熱度

1回答

''模塊「PIP安裝期間在Python3.x中找不到」'找不到''

我有一個小問題，我的Discord bot是用Python編寫的，而且我不斷收到錯誤。這是我的機器人的代碼： import discord import asyncio client = discord.Client() @client.event async def on_ready(): print('Logged in as') print(client.us

1熱度

1回答

如何重用aiohttp ClientSession池？

文檔說重複使用ClientSession：不要爲每個請求創建會話。最有可能你需要一個會話，每個應用程序完全執行所有請求。會話中包含連接池，連接重用和keepalive（默認情況下都處於打開狀態）可能會加速整體性能。 1 但是在文檔中似乎沒有關於如何做到這一點的任何解釋？有一個例子可能是相關的，但它並沒有說明如何在其他地方重新使用該池：http://aiohttp.readthedocs.io

2熱度

1回答

打印響應部分完成Python的異步事件循環，同時還完成任務的響應

我與中信高科工作後，但我有點卡住了。我打電話給3個不同的API，每個都有自己的響應時間。我想創建一個超時功能，它爲每個任務返回一個可接受的時間。但是如果時間任務在可接受的時間內沒有完成，我想返回部分數據，因爲我不需要一個完整的數據集，速度更關注。不過，我想保持未完成的任務工作，直到完成（即請求API數據插入到一個Postgres數據庫。我想知道，如果我們能做到這一點，而無需使用某種調度到保持