问题标签 [aiohttp]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
6793 浏览

python-3.x - aiohttp有ORM吗?

有一个相对较新的 Python 3 aiohttp库,其中包含客户端/服务器。它包含ORM吗?如果不是 - 是否可以将它与 3-rd 方 ORM 一起使用?如果不可能 - 它可以用于什么目的?我并不是说没有 ORM 就不能编写应用程序,而是 Python 框架支持它的主要浪费,并且开发人员已经习惯了这种编程风格。

0 投票
2 回答
16926 浏览

python - Asyncio RuntimeError: Event Loop is Closed

I'm trying to make a bunch of requests (~1000) using Asyncio and the aiohttp library, but I am running into a problem that I can't find much info on.

When I run this code with 10 urls, it runs just fine. When I run it with 100+ urls, it breaks and gives me RuntimeError: Event loop is closed error.

The stack trace can be found here.

Any help or insight would be greatly appreciated as I've been banging my head over this for a few hours now. Obviously this would suggest that an event loop has been closed that should still be open, but I don't see how that is possible.

0 投票
3 回答
4202 浏览

python - aiohttp 中基于类的视图

使用基于类的处理程序而不是aiohttp库中的函数的正确方法是什么?我习惯于在Django中将处理程序编写为类,所以我想知道如何在aiohttp中正确执行它?

0 投票
1 回答
1097 浏览

python - Aiohttp-Asyncio 中的缓存函数

我正在尝试使用 memcached 从 aiohttp 缓存一个函数。缓存我想做一个装饰者。调用装饰器的示例如下所示:

处理缓存的函数装饰器如下所示:

但我在控制台中收到错误:

据我了解的问题:

如果可能,如何序列化/反序列化响应,如果不可能,如何缓存结果 - 有一些解决方法?

0 投票
1 回答
2612 浏览

python - 逐步创建异步任务并等待所有任务完成

我正在尝试编写一个程序来与我创建的服务器建立大量网络套接字连接:

问题是所有的客户一个接一个地做他们的工作:

我尝试过使用asyncio.wait,但所有客户端都是一起开始的。我希望它们逐渐创建并在每个创建后立即连接到服务器。同时继续创造新客户。

我应该采用什么方法来实现这一点?

0 投票
0 回答
73 浏览

python - aiohttp post request Worker 在服务请求时崩溃

在这里,我试图从其他 web api 源收集数据。但是当我并行运行 4-5 个任务 fetch_page 时。

我收到“工人在服务请求时崩溃”

请建议我一些方法来摆脱这个问题。

我也收到大量来自 aiohttp.post 请求的数据响应,所以有时 write.write 方法无法将数据写入客户端

0 投票
3 回答
3131 浏览

python - Python 3.5 async for 阻塞 ioloop

我有一个带有两个处理程序的简单 aiohttp-server。async for第一个在循环中进行一些计算。第二个只是返回文本响应。not_so_long_operation返回具有最慢递归实现的第 30 个斐波那契数,大约需要一秒钟。

当我尝试获取/then/lol/时,它只会在第一个完成时给我第二个响应。
我在做什么错以及如何让索引处理程序在每次迭代时释放 ioloop?

0 投票
1 回答
4047 浏览

python-3.x - TypeError('不是一个有效的非字符串序列或映射对象',)

我正在使用 aiohttp get 请求从另一个 Web api 下载一些内容,但我收到:

以下是我要发送的数据。

如何解决?

我尝试了两种方式:

同时我可以使用以下方法获取数据:

但我需要异步实现。

如果我可以使用import requests库而不是import aiohttp发出异步 http 请求,还建议我采取一些方法,因为在许多情况下,aiohttp 发布和获取请求不起作用,但对于 requests.get 和发布请求同样适用。

0 投票
1 回答
1272 浏览

python - 如何在 Python 中使用 aiohttp 或 asyncio 创建并行循环?

我想使用 rethinkdb .changes() 功能向用户推送一些消息。消息应该在没有来自用户的任何请求的情况下发送。

我正在将 rethinkdb 与 aiohttp 和 websockets 一起使用。这个怎么运作:

  1. 用户发送消息
  2. 服务器放入rethinkdb
  3. 我需要什么:一个额外的循环使用 rethinkdb.changes函数向连接的用户发送更新

这就是我启动应用程序的方式:

wshandler我有一个循环,它处理传入的消息:

如何创建第二个循环将消息发送到同一个打开的连接池?如何使其线程安全?

0 投票
1 回答
1597 浏览

python - asyncio return "任务被破坏,但它正在等待处理!"

我是异步编程的新手。我正在尝试编写用于检查网页状态的脚本。当然,我想这样做是异步的。我的片段:

但是我遇到了下一个错误:Task was destroyed but it is pending! 有人可以指出我犯错的地方吗?