python-asyncio

0熱度

2回答

我正在嘗試編寫一個不和諧的機器人程序，它使用我從http休息調用中獲取的數據更新用戶。由於discord.py使用asyncio，我想我會嘗試按照這種方法。 async def my_background_task(): print("starting BG task") await client.wait_until_ready() while not clie

0熱度

1回答

從期貨ASYNCIO

我疑惑得到以下與ASYNCIO工作：下面的代碼片段被查詢多個設備（通過SNMP），並返回一個字典，它工作正常，但由multiprocessing.cpu_count()限制 def do_polling(netelement, snmp_comm): msg = {} msg.update({ 'bgp' : do_lookup_bgp(netelement,

3熱度

1回答

如何使用aiohttp.ClientSession（）發出請求時爲aiohttp.client設置日誌記錄？

我有一些代碼向某些API發出請求的請求序列。我想爲所有人建立通用日誌記錄，我如何設置它？比方說，我的代碼看起來像這樣 import aiohttp import asyncio async def fetch(client): async with client.get('http://httpbin.org/get') as resp: assert resp.st

6熱度

1回答

ASYNCIO事件環路閉合

當試圖運行在文檔中給出的ASYNCIO的hello world代碼示例： import asyncio async def hello_world(): print("Hello World!") loop = asyncio.get_event_loop() # Blocking call which returns when the hello_world() corout

2熱度

1回答

python asyncIO如何暫停和恢復任務？

一種編程風格，其中任務在等待期間釋放CPU，以便其他任務可以使用它。要引入異步任務，任務應該能夠暫停&恢復事件調度應該安排這些任務（準備好時）寫事件scheduler，但卡在啓用異步task。假設任務被IO綁定。調度程序在任務執行過程中不會獲得CPU分片，因爲任務會同步執行。 Python中的任務（bar），成爲異步任務（可暫停&恢復），當任務使用async，await關鍵字與ayncio

0熱度

2回答

Asyncio標準輸出 - 失敗

我正試圖抓住使用asyncio來加速調用外部工具來分析多個音頻文件的過程。我正在研究windows，python 3.6（anaconda安裝），我在這裏遇到的問題是調用似乎沒有等待，或者結果從來沒有通過stdout接收。任何想法？ import os import asyncio external_tool = r"C:\path\to\external\tool.exe" def

1熱度

1回答

如何在兩個Python asyncio協程之間使用讀/寫流？

如何使用asyncio在兩個協程之間實現管道，一個從流中讀取，另一個寫入其中？假設我們有這個現有的代碼，兩個簡單的腳本。一個產生到stdout： # produce.py import asyncio import random import sys async def produce(stdout): for i in range(10000): await

0熱度

1回答

Python websocket卡住

我有一個可以通過websocket端點使用的python服務器。在服務連接期間，它也與一些後端服務進行通信。這種通信是異步的，可能會觸發websocket的send（）方法。當一個客戶端供應，似乎工作正常。但是，當並行服務多個客戶端時，處理連接的一些例程偶爾會卡住。更確切地說，它似乎阻止了recv（）方法。實際的代碼是有點複雜，問題會更復雜一些比我所描述的，不過，我提供最少的代碼框架是素描的

25熱度

2回答

從流中產生的正確方法是什麼？

我有用於包含讀和寫的asyncio連接流的Connection對象： class Connection(object): def __init__(self, stream_in, stream_out): object.__init__(self) self.__in = stream_in self.__out = stream_out

3熱度

1回答

使用ASYNCIO與封閉代碼

首先，我看了看this，this和this和而第一有一些有用的信息，因爲我試圖遍歷值不是與此有關。這是我希望能夠做的事情的例子： class BlockingIter: def __iter__(self): while True: yield input() async def coroutine(): my_iter = BlockingIt