Tenho no meu software um loop de eventos do asyncio
que está rodando diversas tarefas e agora quero adicionar um servidor HTTP para ouvir requisições vindas da rede local. Mas tem um problema: aparentemente, o "App
", que é o servidor aiohttp
, cria um loop de eventos próprio e não consigo encontrar um jeito de acoplá-lo ao meu loop. Veja o código abaixo:
import asyncio
from aiohttp import web
loop = asyncio.new_event_loop()
loop.call_soon(lambda: print('O loop está rodando!'))
app = web.Application()
routes = web.RouteTableDef()
@routes.get('/')
async def index(request):
print('Requisição recebida!')
return web.Response(text='Resposta do server aiohttp')
app.add_routes(routes)
web.run_app(app)
loop.run_forever()
Estou criando um loop que deve fazer um print
logo que ele começar a rodar. Logo em seguida, crio um servidor simples e começo a rodá-lo (penúltima linha, web.run_app(app)
). Só que essa chamada bloqueia, então a linha loop.run_forever()
nunca chega a ser executada. Não encontrei na API nenhuma função relacionada a executar em um loop externo.
Bem, eu poderia naturalmente usar threads para fazer isso, mas daí eu perderia todo o ponto de se usar assincronismo. Existe alguma maneira de executar um servidor aiohttp num loop de eventos externo?
Nota: para mim, é importante que isso seja feito assim porque este programa está destinado a rodar em um hardware limitado; todos os outros núcleos estarão destinados a cuidar de outras tarefas e a memória é escassa também. Logo, preciso que as atividades não tão cruciais (como esta) sejam abarcadas pelo loop. Como o colega @Augusto pontuou, em condições normais provavelmente seria mais inteligente transferir o servidor para um processo separado.