python-asyncio

1热度

2回答

我正在尝试使用aiohttp Server来构建服务。但是我需要确保所有的响应正确处理CORS头，并且所有的错误都返回一个JSON响应。我该如何实现这样的事情？

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（）方法。实际的代码是有点复杂，问题会更复杂一些比我所描述的，不过，我提供最少的代码框架是素描的

0热度

2回答

asyncio.create_subprocess_exec控制台窗口为每个调用打开

我有一个函数，它异步运行子进程命令并返回结果。它看起来像这样： import asyncio async def async_subprocess_command(*args): # Create subprocess process = await asyncio.create_subprocess_exec( *args, # stdout and