此标记用于asyncio Python包，它提供了编写单线程并发代码的机制。 asyncio包提供从Python 3.4开始的异步I / O，事件循环，协同程序和任务。
AWS Lambda FastAPI Firehose 问题[重复]
我有一个在 AWS Lambda 上运行的简单 FastAPI REST 服务器。它使用 AWS Kinesis Firehose 将日志写入 S3。我从异步单个 Firehose 写入开始，速度非常慢。然后我想出了一个
我的以下功能未按预期运行。它是一个异步函数，我希望它能够在响应为 401 并且锁未锁定时删除 api_keys 中的第一个值。当...
如何将 HTTP 请求从我的 FastAPI 应用程序发送到另一个站点 (API)？
我尝试使用以下代码片段一次向服务器 http://httpbin.org/uuid 发送 100 个请求 从 fastapi 导入 FastAPI 从时间导入睡眠 从导入时间开始 进口需求...
`从...导入fastapp 导入pytest 从 async_asgi_testclient 导入 TestClient 作为 AsyncClient 从 fastapi.testclient 导入 TestClient 客户端 = TestClient(fastapp) @pytest.mark.django_db(
我正在创建一个多人在线游戏，并使用套接字io作为游戏服务器。下面是我的服务器代码 导入套接字 导入时间 从 aiohttp 导入 web sio = socketio.AsyncServer(async_mo...
如何在 SQLAlchemy 中为 ASGI 应用程序正确设置 pool_size （和 max_overflow）
我们正在使用 fastapi、uvicorn、sqlalchemy 和 PostgreSQL 构建 ASGI 应用程序。问题是：我们应该如何在 create_async_engine 中设置 pool_size 以免使其成为与 WSGI 应用程序相比的瓶颈...
要停止以下代码，需要按 Ctrl-C 两次，但是第二个引发的 KeyboardInterrupt 异常不会被 start_consuming 方法内的内部 try-catch 捕获。 导入
异步下载多个 blob - Azure Function - 检查运行循环
在[上一个问题][1]中，我问了如何异步下载数据，得到了解答。但是，在 Azure 函数上运行代码时，出现以下错误 asyncio.run() can not be ...
Databricks：使用 ThreadPoolExecutor 时对函数的异步调用以及使用执行器的并发调用
我们有一个Databricks功能 将请求导入为 req def my_rest_api_call(my_list) 它在内部调用服务 URL resp = req.post(url = serviceUrl, data = webParams) 这又回来了
API 通常有用户必须遵守的速率限制。作为示例，我们以每秒 50 个请求为例。顺序请求需要 0.5-1 秒，因此速度太慢，无法接近该限制。平行
我有一个使用 FastAPI 构建的 API，该端点将任务提交给 celery 工作人员，等待工作人员完成其工作并将结果返回给用户。 问题是等待
为什么asyncio.run()或loop.run_until_complete()会运行已创建但未等待的任务？
这是代码。 导入异步 异步 def run_test(): 打印（“运行1”） 等待 asyncio.sleep(1) 打印（“运行2”） 异步 def main(): 打印（“主1”） 循环=
我正在尝试使用异步和线程来找出在处理大量文件时应该选择哪种机制。实验很简单，我只是想读取文件并添加...
在Python的asyncio库中，哪些方法创建事件循环？是 asyncio.run() / asyncio.get_event_loop() 吗？还有哪些方法开始运行事件循环？我尝试寻找；但它确实...
我有以下一段Python异步代码。 导入异步 异步 def get_some_values_from_io(): print("获取一些值执行...") 等待 asyncio.sleep(3) 返回 [100...
如何在 Jupyter Notebook 中的同步上下文中正确安排和等待异步代码中的结果？
我有一个小实用程序，用于使用 asyncio 并行调用同步代码。 导入异步 从并发.futures 导入 ThreadPoolExecutor 从 asyncio 导入 AbstractEventLoop, BaseEventLoop ...
Python 包 - aiohttp 有警告消息“未关闭的客户端会话”
我的代码如下： 导入异步 导入 aiohttp 网址 = [ 'http://www.163.com/', 'http://www.sina.com.cn/', ] 异步 def get_url_data(u): resp = 等待 aiohttp.ClientSession().get(u...
`await asyncio.sleep(0)` 与 `loop.run_in_executor()` 不并发
awaitloop.run_in_executor(executor, open_read) 不会返回，直到await asyncio.shield(get_audio_async(sentence)) 产生对事件循环的控制。我将await asyncio.sleep(0) 调用放入no ...
导入异步 异步 def long_running_task(): 尝试： 而真实： # 你的长时间运行的处理 如果 asyncio.current_task().cancelled(): 引发异步。
我正在制作一件艺术品。它由多个树莓派 picos 组成。使用 micropython 进行编码。 有一个基于 RPi pico 的远程控制，其作用类似于 Web 服务器，提供