asyncio向循环中动态添加协程

文章/答案/技术大牛

发布

1回答

python、python-3.5、python-asyncio、aiohttp

假设目录中的文件数量可以从10到100 -我决定使用asyncio和aiohttp并发发送请求。BASE_DIR = '/path/to' while True: if os.path.join(BASE_DIR, file).endswi

浏览 14提问于2016-07-20得票数 6

回答已采纳

1回答

从同步代码中调度任务以运行事件循环

python、python-asyncio、coroutine

考虑这个程序，其中用于停止它的主循环和协程实际上是由我正在使用的一个库实现的。import asyncio global runningloop.run_until_complete(mainloop())当程序收到信号时，我需要调用stop协程来停止主循环。虽然在使用asyncio.BaseEventLoop.creat

浏览 43提问于2018-01-28得票数 1

回答已采纳

1回答

检测协程是否需要异步循环

python、asynchronous、twisted、python-asyncio、coroutine

我正在编写使用Twisted在用户提供的协程上等待的代码。在一个更简单的例子中，我所需要的就是使用defer.ensureDeferred将协程转换为延迟。但是，如果协程使用asyncio.sleep()，我需要使用asyncio.ensure_future将其包装到异步任务中，该任务将在异步循环中运行，这需要AsyncioSelectorReactor。我希望支持第一种情况，即使没有使用AsyncioSelectorReactor，

浏览 13提问于2019-08-23得票数 4

1回答

asyncio从协程获取结果

python-3.x、python-asyncio

我有一个任务是在异步和python3帮助下在协程之间进行通信。请告诉我怎么做，如果一个协程，在while tru循环中，以不同的时间间隔返回值，而其他协程接收到这个数据。import asyncio def write(future): while True: yield from asyncio.sleepfuture.set_result('

浏览 2提问于2016-12-16得票数 1

1回答

在Aiohttp应用程序中管理长时间运行的任务

python-asyncio、aiohttp

服务器使用new_task = asyncio.create_task()创建任务生成新任务的uuid，并将其全部保存在字典中：uuid_task

浏览 56提问于2019-04-30得票数 1

回答已采纳

1回答

在asyncio中，"yield from“语法是做什么的?它与"await”有什么不同？

python、async-await、generator、python-asyncio、coroutine

从已经编写了异步代码但希望更好地理解内部工作原理的人的角度来看，什么是yield from、await，以及它们对允许异步代码有什么用处？

浏览 2提问于2017-05-30得票数 52

回答已采纳

2回答

相当于Python的"async def“函数中的"yield”

python-asyncio

我听说@asyncio.coroutine版本的协程最终将在Python中被弃用(可能在3.8之后？)，并且只支持async def。今天，我使用装饰器版本是为了能够只使用yield (而不是yield from另一个协程)，因为我正在等待一些变化(例如while循环中的轮询)，或者将大部分耗时的阻塞代码拆分成更小的块(从而改善并发体验下面是一个最小的例子：def foo(l):

浏览 14提问于2018-08-23得票数 4

回答已采纳

1回答

如何在单元测试时异步地从db中获取记录？

python、sqlalchemy、fastapi

query) assert d.expires_at == datetime.utcnow().replace(microsecond=0) + timedelta(days=7) 因为d是一个协程对象

浏览 42提问于2021-02-03得票数 2

回答已采纳

2回答

递归函数的Asyncio loop.run_until_complete()

python、recursion、python-3.5、future、python-asyncio

get_soup(base_url) dest = link.get('href') in_fut = asyncio.ensure_futureset_result)

浏览 1提问于2016-11-29得票数 1

2回答

如何设置异步任务的名称？

python-asyncio、python-3.6

有没有可能用asyncio.Task做这样的事情

浏览 8提问于2017-01-23得票数 6

回答已采纳

1回答

异步协同例程似乎没有结束

python、asynchronous、python-3.6

我想使用Python3.5的async/await语法和asyncio来异步这些调用。somedir/*.dbf") results = loop.run_until_complete(asyncio.gatherreturn sizes return os.path.split(path)[-1], os.stat(path).st_size loop = a

浏览 1提问于2017-04-14得票数 0

1回答

Asyncio如何收集可变数量的corroutines？

python、python-asyncio

loop.run_until_complete(asyncio.gather( account1.client.start(account.credentials

浏览 2提问于2018-02-08得票数 1

回答已采纳

1回答

如何停止()多个嵌套异步循环中的最后一个循环？

python、loops、python-asyncio、halt

我有时需要多个异步协程，其中例程将被嵌套:协程B在协程A中运行，C在B中运行，依此类推。问题在于停止给定的循环。例如，在最后一个顶级循环中使用loop.stop()，比如循环'C‘，实际上会杀死所有异步协程--而不仅仅是这个循环'C’。我怀疑stop()实际上杀死了协程A，并且通过这样做它消除了所有其他依赖的例程。嵌套的例程是call_soon_threadsafe，并且所有例程

浏览 2提问于2015-06-11得票数 0

1回答

使用Python中的协程正确捕获语法错误

python、error-handling、async-await、python-asyncio

我来自JavaScript，正在尝试使用Python的async/await协程特性，但我在让它按我期望的方式工作时遇到了一些问题。让前两个函数并行运行非常容易。我遇到的问题与捕获语法错误有关。具体地说，我试图在我的一个函数中添加一些数学，但Python似乎只是在这一步上挂起了(在工作之前打印，在它们失败后打印)。我试着用try/except包装整个令人不快的协程，但这似乎破坏了我的其他协程(似乎打破了我对协程如

浏览 67提问于2020-09-28得票数 0

1回答

异步捕获任务中的TimeoutError

python、python-3.x、python-asyncio

我有一个asyncio.Task，我需要在一段时间后取消。在取消之前，任务需要做一些清理。根据文档，我应该只能调用task.cancel或asyncio.wait_for(coroutine, delay)并在协程中拦截asyncio.TimeoutError，但下面的示例不起作用。@asyncio.coroutine try: while True: print("iteration ",

浏览 0提问于2015-06-15得票数 2

回答已采纳

1回答

为什么python asyncio协程在socket.recv(1024)行暂停？为什么while循环不能通过yeild语句？

asynchronous、python-asyncio、coroutine

我有一个小的应用程序，一个协程将发送数据，另一个协程将接收数据和日志，无论它是否收到确切的传输数据。data, server = yield from recv_sock.recvfrom(1024)import socket

浏览 0提问于2017-02-20得票数 1

2回答

从流中获得收益的正确方法是什么？

python、python-3.x、generator、python-asyncio、yield-from

我有一个用于包含asyncio连接的读写流的Connection对象：def new_conection(stream_in, stream_out):def client(loop): ...我的最终目标是将我的new_cone

浏览 11提问于2017-08-27得票数 24

回答已采纳

1回答

使用套接字connect_ex的异步rabbitmq使用者

python、sockets、rabbitmq、python-asyncio

我想写一个python程序，从rabbitmq服务器获取ip和tcp端口，并扫描以检查端口是否打开，因为这些扫描有时成批到来(可能是100个端口，ip对一次添加到队列中)。import asyncioimport socket sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) result = sock.c

浏览 0提问于2020-06-21得票数 0

1回答

python asyncio:异步任务函数的模式

python、python-3.x、task、coroutine、python-asyncio

class InterruptibleTask: self.stop_evt = stop_evt or asyncio.Event(1) await asyncio.create_task(self.do_work()) await asyncio.create

浏览 20提问于2019-12-10得票数 0

1回答

如何调度函数作为后台任务运行

python-3.x、function、synchronization

为我糟糕的措辞道歉，但我要说了。我试图通过对每个函数计时并创建执行其他函数的函数来创建它，然而，无论我尝试什么，它都像任何脚本一样以异步方式运行。def function_1(): pass &

浏览 5提问于2020-02-25得票数 1

回答已采纳

点击加载更多