Я запускаю тестовый веб-сервер aiohttp:
#!/usr/bin/env python3
from aiohttp import web
import time
import asyncio
import random
import string
import logging
logger = logging.getLogger('webserver')
logger.setLevel(logging.INFO)
handler = logging.StreamHandler()
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
handler.setFormatter(formatter)
logger.addHandler(handler)
def randomword(length):
return ''.join(random.choice(string.ascii_lowercase) for i in range(length))
async def hello(request):
sleeptime = 10 # seconds
requestid = randomword(5)
logger.info("Request id: {} received - will sleep for {}".format(requestid, sleeptime))
await asyncio.sleep(sleeptime)
logger.info("Request id: {} wakeup and respond".format(requestid))
return web.json_response()
# create app and register with request handler
app = web.Application()
app.router.add_get('/', hello)
web.run_app(app, port='15000')
Ожидается, что он сможет обрабатывать несколько входящих запросов одновременно, не дожидаясь завершения одного запроса перед обработкой следующего. Однако это не так - обработка идет последовательно (обратите внимание, что время начала 2-го/3-го запроса после завершения предыдущего запроса):
======== Running on http://0.0.0.0:15000/ ========
(Press CTRL+C to quit)
2016-10-23 02:28:23,911 - webserver - INFO - Request id: hpzdo received - will sleep for 10
2016-10-23 02:28:33,922 - webserver - INFO - Request id: hpzdo wakeup and respond
2016-10-23 02:28:33,947 - webserver - INFO - Request id: pdfbs received - will sleep for 10
2016-10-23 02:28:43,957 - webserver - INFO - Request id: pdfbs wakeup and respond
2016-10-23 02:28:43,971 - webserver - INFO - Request id: dmkav received - will sleep for 10
2016-10-23 02:28:53,982 - webserver - INFO - Request id: dmkav wakeup and respond
Я ожидаю, что время начала для каждого запроса будет почти одинаковым (в зависимости от того, как быстро я их отправляю; здесь я отправляю вручную в течение секунды или двух).
