python-asyncio 相关问题

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

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

Всем привет。 Ниже обработчик системных сообщений от ТГ 和 если пользователь вступил в чат или вышел - бот пишет сообщение。 导入远程机器人,配置 bot = telebot.TeleBot(config.Token) @bot.message_ha...

回答 1 投票 0

如何在失败的情况下终止Python中的异步进程

我正在使用 asyncio 异步启动一个进程,然后从 stdout 读取数据,我的代码如下所示: 进程 = 等待 asyncio.subprocess.create_subprocess_exe(subprocess_args,

回答 1 投票 0

属性错误:异步 SQLalchemy 会话中的 __aenter__

使用会话时出现 AttributeError: __aenter__ 错误,如下所示: 异步 def get_session(): SessionLocal = sessionmaker( 自动提交=假, 自动刷新=假, ...

回答 1 投票 0

从协程中提取函数和参数

python3.6中是否可以提取协程对象的函数和参数? 上下文:目前我有这样的事情: 异步 def func(*args): ... ret = 远程等待(func, ...

回答 3 投票 0

在内部,asyncio run_forever() 基本上是一个 while True 循环吗?

python asyncio run_forever 或 while True 类似,但它是一个“我应该这样做......”的问题。 我更想了解 python asyncio 的内部结构是否基本上是 而真实...

回答 1 投票 0

Python Asyncio 并发问题:GPT4 连续函数调用中的混合响应

我遇到了一个令人困惑的 asyncio 问题,在短时间内连续运行我的函数会导致混合响应。该函数向 AI 服务发送提示和数据

回答 1 投票 0

Flask:如何在完整路由代码执行之前返回验证

抱歉新手问题 - 我是 Python 新手。 我必须在主代码执行之前返回 Flask 路由参数的验证结果: @app.route('/', 方法=['POST']) 定义索引(): 验证=

回答 1 投票 0

如何运行多个websocket客户端连接?

我有一个 Django 服务(我们称之为“主”服务),它运行一个 HTTP 服务器和一个使用 django-channels 的 WebSocket 服务器。我还有很多其他 django 服务(称它们为 ta...

回答 1 投票 0

asyncio.TaskGroup 中的键盘中断

任务组的文档说: 特殊处理两个基本异常:如果任何任务因 KeyboardInterrupt 或 SystemExit 失败,任务组仍然取消剩余任务并等待它们,...

回答 1 投票 0

Python 中使用 `asyncio` 进行多个请求

我正在尝试同时提出多个请求。 我是Python中的async和await新手(我在Js中使用过它)。 我找到了一个例子并使用了这个: 导入异步 导入 aiohttp 异步 def get_i...

回答 1 投票 0

在aiobotocore中重用create_client以获得更好的性能

我正在实现一个异步Python代码,它使用aiobotocore将对象放入S3中。 代码是这样的 - 类 Foo: def __init__(自身): self._aiobotocore_session = get_sessi...

回答 1 投票 0

验证 python asyncio 异步运行

我有一个函数,它接受 html 字符串,通过删除停用词来清理它,然后计算用户确定的搜索字符串中单词出现的次数: def clean_text(字符串,

回答 1 投票 0

Python 3.7.4 和 3.10.6 asyncio 在 VS Code 调试调用堆栈中创建多个任务

在使用 asyncio 和 aiohttp 时,遇到了这个问题,想知道这是否仅限于 VSC 发生? 这个循环会留下前一个循环的残留物。 而真实: 循环。

回答 2 投票 0

AWS Lambda FastAPI Firehose 问题[重复]

我有一个在 AWS Lambda 上运行的简单 FastAPI REST 服务器。它使用 AWS Kinesis Firehose 将日志写入 S3。我从异步单个 Firehose 写入开始,速度非常慢。然后我想出了一个

回答 1 投票 0

从 API 异步获取数据时,Asyncio 锁不起作用

我的以下功能未按预期运行。它是一个异步函数,我希望它能够在响应为 401 并且锁未锁定时删除 api_keys 中的第一个值。当...

回答 1 投票 0

如何将 HTTP 请求从我的 FastAPI 应用程序发送到另一个站点 (API)?

我尝试使用以下代码片段一次向服务器 http://httpbin.org/uuid 发送 100 个请求 从 fastapi 导入 FastAPI 从时间导入睡眠 从导入时间开始 进口需求...

回答 3 投票 0

pytest测试结束后不退出

`从...导入fastapp 导入pytest 从 async_asgi_testclient 导入 TestClient 作为 AsyncClient 从 fastapi.testclient 导入 TestClient 客户端 = TestClient(fastapp) @pytest.mark.django_db(

回答 1 投票 0

Socketio 后台任务未运行

我正在创建一个多人在线游戏,并使用套接字io作为游戏服务器。下面是我的服务器代码 导入套接字 导入时间 从 aiohttp 导入 web sio = socketio.AsyncServer(async_mo...

回答 1 投票 0

如何在 SQLAlchemy 中为 ASGI 应用程序正确设置 pool_size (和 max_overflow)

我们正在使用 fastapi、uvicorn、sqlalchemy 和 PostgreSQL 构建 ASGI 应用程序。问题是:我们应该如何在 create_async_engine 中设置 pool_size 以免使其成为与 WSGI 应用程序相比的瓶颈...

回答 2 投票 0

当阻塞工作完成时,键盘中断未被捕获

要停止以下代码,需要按 Ctrl-C 两次,但是第二个引发的 KeyboardInterrupt 异常不会被 start_consuming 方法内的内部 try-catch 捕获。 导入

回答 1 投票 0

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