python-asyncio 相关问题

此标记用于asyncio Python包,它提供了编写单线程并发代码的机制。 asyncio包提供从Python 3.4开始的异步I / O,事件循环,协同程序和任务。

异步添加到队列,同步处理

我的 EventHandler 类中有一个函数 def event(...) ,可以在我的主代码中以任意间隔调用它。它需要将所有进入的事件放入队列并处理它们...

回答 1 投票 0

Asyncio:如何从子进程读取标准输出?

我遇到了一个非常简单的问题 - 我无法与进程的标准输出进行通信。 该过程是一个简单的秒表,因此我能够启动、停止并获取当前时间。 秒表的代码...

回答 1 投票 0

TypeError:对象 NoneType 不能在“await”表达式中使用

我试图从我的 Flask-socketio 服务器调用函数 从flask_socketio导入发出 导入异步 异步 def myfunc(): 对于范围(10)内的 i: j = 1*3 等待发出('更新...

回答 3 投票 0

不清楚程序退出时python异步任务取消/关闭

我在这里找不到清楚描述该机制的文档,所以只想尝试理解和学习最佳实践。对于由 asyncio.create_task 创建的任务,它们似乎在程序中被清理...

回答 1 投票 0

使用 grpc.aio python 记录拦截器

我找不到 python 日志拦截器的示例实现来测量处理请求所需的时间。 我想测量服务器上处理请求需要多长时间

回答 1 投票 0

asyncio的create_datagram_endpoint调用了多少次connection_made?

Python 的 asyncio 示例展示了如何为 TCP 回显服务器创建“协议类”。该示例似乎表明这些对象为每个客户端连接生成。在这种情况下:connection_m...

回答 1 投票 0

Python TCP 服务器使用异步流(独立)发送和/或接收数据?

我有一个使用 asyncio 的基于 python 的 TCP 服务器,但它有一个特定的行为:TCP 客户端(PLC)连接到应用程序,但实际上服务器或客户端都可以启动数据流。一旦...

回答 1 投票 0

asyncio.sleep可以停止吗?

你能阻止 asyncio.sleep() 休眠吗?我想在等待 20 秒后或布尔值为 true 时在协程中运行一些代码,有什么办法可以做到这一点吗?我只能想到实现...

回答 1 投票 0

telethon.errors.rpcerrorlist.FileReferenceExpiredError:文件引用已过期且不再有效

版本: 蟒蛇:3.10.12 马拉松:1.34.0 下面从 telegram 下载媒体文件。 导入异步 导入临时文件 从 telethon 导入 TelegramClient 从 telethon.tl.types 导入

回答 1 投票 0

Python 中异步函数的命名约定是什么?

在Python课程中,当你必须混合同步和异步函数时,最佳实践是什么? 第一个选项: 类我的类: def myfct_sync(...) 异步 def myfct_async(...) 第二次手术...

回答 1 投票 0

Python - 在同步方法中等待 websocket 响应

我面临 Asyncio、Web 套接字和同步调用的问题。 我们有一个使用 websockets 和 Flask 的应用程序。 Websocket 使用 asyncio 进行管理,我们接收消息 异步 def on_message(

回答 1 投票 0

asyncio“任务已被销毁,但正在等待处理!”在 pysnmp 示例程序中

我正在测试 pysnmp asyncio 模块,并作为开始使用随文档一起提供的示例程序。当我运行示例程序时,它给出任务已被破坏但它正在挂起! ...

回答 2 投票 0

如何在 Python 中迭代 AsyncIterator 流并设置超时而不取消流?

我正在处理一个 AsyncIterator[str] 对象。 它从网络获取消息,并将它们作为字符串生成。 我想为此流创建一个包装器来缓冲这些消息,并且...

回答 1 投票 0

程序收到中断信号后websockets无法通信

我的服务器: 导入网络套接字 异步定义处理程序(ws): ws 中的消息异步: 打印(消息) wait ws.send('已收到' + 消息) 服务器 = 等待 websockets.serve(handler, 'localhost', 22235...

回答 1 投票 0

为什么在调用异步函数之前会打印该函数的输出?

异步函数的行为是不同的,尽管它们几乎是相同的代码,但我不明白为什么。 我的代码是: 导入异步 异步 def func1(): 等待 asyncio.sleep(1) 优先...

回答 1 投票 0

如何将 Python 多线程套接字客户端/服务器转换为 asyncio?

我正在编写一个工具来端到端测试基于异步的服务器。最初,我打算在一个终端窗口中启动服务器,并在一个单独的窗口中运行测试,但后来我意识到它

回答 1 投票 0

为什么我的函数没有异步运行(asyncio to_thread)?

从这个视频中学习,我正在努力让我的代码运行得更快。 我有一个同步获取函数(此处由 mySynchronousFunction 表示),我想对列表中的多个值进行评估...

回答 1 投票 0

定期在Python协程/任务中工作或退出

对Python来说完全陌生。我想编写一个简单的异步函数,它每 N 秒执行一次 ps $pid ,直到收到停止信号。 即在 go 中它只是: go func(cancelCtx context.Context) { ...

回答 1 投票 0

使用 async 异步填充 Pandas Dataframe

我刚刚看到了来自 Idently 的这段很棒的视频,并尝试使用该技巧根据另一个视频填充一些数据帧列。 这是我的 MWE(实际上更像是非工作示例)代码,我在

回答 1 投票 0

我对这个简单的异步示例的理解有什么错误

我不知道如何使用aynchio。你能帮我解决这个问题吗?假设我有一些 IO 任务,我将其放入协程任务()中,需要 8 秒。我想运行一个 inf...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.