python-asyncio

2熱度

1回答

我寫這段代碼： import asyncio import threading from aiohttp import ClientSession async def fetch(url): async with ClientSession() as session: async with session.get(url) as response: re

6熱度

2回答

在Python中限制異步函數Asyncio

我有一個list的awaitables，我想傳遞給asyncio.AbstractEventLoop，但我需要限制對第三方API的請求。我想避免一些等待將future傳遞到循環，因爲在此期間我阻止了我的循環等待。我有什麼選擇？ Semaphores和ThreadPools將限制同時運行多少個，但那不是我的問題。我需要將我的請求限制到100 /秒，但完成請求需要多長時間無關緊要。這是一個非常簡潔

5熱度

1回答

調試並列出未來在python asyncio

未決的所有協同程序我有一個生產代碼，嚴重使用asyncio.semaphore模塊懷疑有死鎖問題。我已經找到了一些如何附加到unix信號運行python代碼的解決方案，使用ipdb.set_trace()進行調試，並在asyncio.Task.all_tasks()上列出了事件循環中的所有任務。我是否可以進一步檢查每個任務的堆棧框架，或查看目前正在等待期貨的每條協同程序行ipdb？

5熱度

2回答

如何用Ctrl + C優雅地關閉協程？

我在寫蜘蛛來抓取網頁。我知道asyncio也許是我的最佳選擇。所以我使用協程來異步處理工作。現在我抓住了我的頭如何通過鍵盤中斷退出程序。所有作品完成後，該程序可能會關閉。源代碼可以在python 3.5中運行，並在下面註明。 import asyncio import aiohttp from contextlib import suppress class Spider(object):

1熱度

2回答

在asyncio中測試永久運行的任務

我需要每秒調用一次任務（例如）來輪詢某個硬件上的某些傳感器數據。在單元測試中，我想要做的就是檢查是否調用了正確的方法，並且錯誤（例如傳感器已被炸燬或消失）確實被捕獲。這裏是一個玩具例如模仿真正的代碼： import pytest import asyncio import mock async def ook(func): while True: await as

1熱度

1回答

Python中，ASYNCIO：裝飾類，以簡化循環語法

讓我們考慮含有ASYNCIO環和一個異步協程類的下面的例子： import asyncio class Async: def __init__(self): self.loop=asyncio.get_event_loop() async def function(self, word): print(word) await async

0熱度

1回答

python的asyncio可以做些什麼來改善這種功能？

while True: if (len(queue) > 0): blocking_send_from_queue() there_is_something_to_send = False else: break data = non_blocking_recv() queue = process(queue

1熱度

1回答

爲什麼BeautifulSoup與'任務異常從未檢索'相關？

我想使用協程來抓取和解析網頁。我寫了一個樣本和測試。該程序可以在Ubuntu 16.04的python 3.5中運行良好，當所有作品完成後它將退出。源代碼如下。 import aiohttp import asyncio from bs4 import BeautifulSoup async def coro(): coro_loop = asyncio.get_event_lo

-1熱度

1回答

如何確保只有單個進程在線程中運行

我有一個類方法coroutine類，並從一個用戶同時獲得多個請求，假設用戶在t = 0進行函數調用，並且函數需要10毫秒的過程，用戶在t = 3毫秒時進行另一次異步調用，然後在t = 10毫秒時響應請求1，並且在t = 20ms時響應請求2，所以請求2的轉換時間爲17毫秒，但是我想要下面的場景，如果請求1來自t = 0ms的一個用戶，並且在請求2進入t = 3ms之前運行3ms，那麼調用1必須被

1熱度

2回答

如何緩存所有asyncio響應以確保它們具有CORS標頭和JSON響應？

我正在嘗試使用aiohttp Server來構建服務。但是我需要確保所有的響應正確處理CORS頭，並且所有的錯誤都返回一個JSON響應。我該如何實現這樣的事情？