aiohttp

0热度

1回答

我开发了一个服务，充当网关，将请求重定向到不同的微服务。为此，我使用aiohttp来处理重定向请求，gunicorn（w/aiohttp.worker.GunicornWebWorker）服务，Heroku作为主机。在本地工作一切都很完美，100％的请求返回响应，客户端总是收到所需的信息，但是当我部署到Heroku并重定向一些请求时（每分钟5k），我发现有3到7个HTTP状态请求503超时错误。

2热度

1回答

提取从aiohttp POST请求的JSON之后的参数

目前我做这样的事情 app.router.add_route('POST', '/foo/{par}', foo_test) 我如何可以提取POST的身体要求 @asyncio.coroutine def foo_test(request): body = request.content.read() #returns a generator 我的问题是如何提取发电机机身返回？

3热度

1回答

如何实现redis会话在aiohttp中过期

我在aiohttp redis会话中找不到redis会话到期实现。会话保存在redis中，但后来我检查了ttl AIOHTTP_SESSION_C8A63762a87d4c01a64991e268c35f54没有会话密钥的ttl。如何实施到期以避免旧会话增长？我想集 expire 'AIOHTTP_SESSION_'+session.identity 300 在会话中间件的每一个请求，是方便

4热度

1回答

与aiohttp Web服务器

我aiohttp网络服务器共享状态使用随时间变化的全局变量： UnboundLocalError: local variable 'shared_item' referenced before assignment 我将如何正确使用共享变量shared_item： from aiohttp import web shared_item = 'bla' async def handle(r

0热度

1回答

响应用户并继续运行异步功能

我想，只要我收到请求响应用户，然后继续将数据保存到数据库 async def index(request): data = await request.post() response.write("done") async with request.app.mysqlpool.acquire() as conn: async with conn.curso

1热度

1回答

aiohttp.web + aiopg + SQLAlchemy的：随机“cursor.execute（）呼吁，而另一个协程已经等待传入的数据”负荷

下，我有一个小小的aiohttp.web应用程序，通过aiopg SQLAlchemy的整合执行SQL请求。 import aiohttp.web from aiopg.sa import create_engine app = aiohttp.web.Application() async def rows(request): async with request.app[

3热度

1回答

在Flask中异步传输大文件

在Flask中异步传输大文件的最佳方法是什么？我已阅读此。但我想知道是否有一种方法可以在不使用芹菜的情况下做到这一点。在此先感谢

1热度

1回答

在aiohttp中为静态文件启用gzip压缩

我试图在静态文件中的aiohttp中启用压缩。我试图创建一个自定义的响应： import aiohttp class GzipResponse(aiohttp.web.StreamResponse): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self.enab

3热度

1回答

未来的例外从未检索

我有一个刮板（基于Python 3.4.2和asyncio/aiohttp库）和一堆链接（> 10K）来检索一些少量的数据。刮板代码部分： @asyncio.coroutine def prepare(self, links): semaphore = asyncio.Semaphore(self.limit_concurrent) tasks = [] resu

2热度

1回答

如何确定每秒使用aiohttp的请求数？

我正在尝试使用aiohttp创建一个网站流量模拟器。以下代码示例异步发出10k个请求。我想知道他们中有多少人同时发生，所以我可以说这是10k用户同时请求网站的模型。如何确定并发网络请求的数量，或者如何确定aiohttp每秒请求多少个请求？有没有办法实时调试/分析并发请求的数量？有没有更好的方法来使用任何其他编程语言来建模网络流量模拟器？ import asyncio import aioht