python-asyncio

1熱度

1回答

我對Python的等待和哈瓦的例子有所懷疑，它試圖使用await從未來的obj中獲取結果。 import time import asyncio import time import random import threading db = { "yzh": "pig", "zhh": "big pig" } loop = asyncio.get_event_l

1熱度

1回答

Python asyncio資源不可用

我有一個應該連續發送數據並等待客戶端提示停止，設置變量或傳輸日誌文件內容的python服務器。目前我只是試圖從客戶端恢復提示。我試圖利用ASYNCIO這樣做，但我遇到了以下錯誤：（，BlockingIOError（11 '資源暫時不可用'））我的服務器代碼： loop = asyncio.get_event_loop() async def server(): s = soc

4熱度

1回答

我需要在eventloop中包含我所有的功能嗎？

如果我有一個事件循環和異步功能： # asyncio_coroutine_forever.py import asyncio async def hello_world(): print('Hello World') await good_evening() async def good_evening(): print('Good Evening')

0熱度

1回答

使用扭曲回調的異步/等待語法

我想用Twisted Deferred.addCallback方法使用async/await語法。但正如文檔中所述，addCallback回調被稱爲同步。我已經看到inlineCallbacks用於此目的的裝飾器，但我更喜歡使用async/await語法（如果它甚至可能或有意義）。我從pika documentation拿起原來的代碼，但我沒有運氣試圖遷移至異步/ AWAIT語法： import

1熱度

2回答

如何在不等待的情況下調用異步函數？

我在aiohttp應用程序中有一個控制器操作。 async def handler_message(request): try: content = await request.json() perform_message(x,y,z) except (RuntimeError): print("error in perform fb me

2熱度

1回答

爲什麼我在Windows上獲取NotImplementedError異步並等待？

我有這樣的代碼： import os import time import asyncio async def run_command(*args): """ Example from: http://asyncio.readthedocs.io/en/latest/subprocess.html """ # Create subpro

-1熱度

1回答

discord.py edit_server函數示例

之前我嘗試使用函數edit_server，如discord.py文檔所列：http://discordpy.readthedocs.io/en/latest/api.html?highlight=ownership，並且無法弄清楚如何使用它。我想用它來創建一個命令將所有權轉讓給其他用戶。我的代碼： elif message.content.startswith('!ownership):

-2熱度

1回答

使用AsyncIO和aiohttp來抓取網站並收集所有網址的程序

使用這種異步（更快）的解決方案，您可以從網站收集所有網址，並將它們寫入與程序相同的目錄中的文本文件中。這些文本文件可以用於進一步爬行或作爲數據庫使用，也可以定期進行比較。原始代碼已被我修改，使其工作並做我想要的東西。你可以增加並行任務的數量或任何你喜歡的。如果您想出一些好的解決方案，請隨時在這裏發佈您的修改。我有一些想法的分佈式計算HTML，JavaScript的蟒蛇 #!/usr/bin/

4熱度

1回答

Python asyncio：在工作線程上運行subprocess_exec

因此，我使用Python asyncio模塊（在Linux上）啓動子進程，然後對其進行異步監視。我的代碼工作正常......當在主線程上運行。但是，當我在工作線程上運行它時，它會掛起，並且從不調用回調函數。我懷疑這可能實際上是某種未公開的缺陷或在工作線程上運行subprocess_exec問題，可能與實現在後臺線程中處理信號的方式有關。但它也可能只是我搞砸了。一個簡單的，可再現的例子是如下：因

3熱度

2回答

如何等待對象改變狀態

在我的async處理程序內我想等到任務的狀態改變。現在，我只是無休止地檢查狀態並等待。下面是一個例子，wait_until_done功能： import asyncio class LongTask: state = 'PENDING' my_task = LongTask() def done(): my_task.state = 'DONE' async