Как правильно вызывать асинхронный код в обычном обратном вызове? Этот код работает, но выглядит некрасиво. Мне не нравится, как вызывается ответ: ему нужно передать адрес вызывающего абонента через все функции. Как установить тайм-аут для обработчика?
Я размещал вопросы в комментариях.
import asyncio
import logging
logger = logging.getLogger('protocol')
async def echo(data):
#external lib emulator
data = b'>'+data
await asyncio.sleep(1)
return data
class Protocol(asyncio.DatagramProtocol):
def connection_made(self, transport):
logger.debug('connection_made called')
self.transport = transport
def respond(self,task):
logger.debug('respond called')
# i want to get data in attrs, not task
resp,caller = task.result()
self.transport.sendto(resp, caller)
async def handler(self,data, caller):
logger.debug('handler called')
# async needed for `await` and `async for` external library such motor, etc
# do some awaits
data = await echo(data)
# simple echo
return (data, caller)
def datagram_received(self, data, addr):
logger.debug('datagram_received called')
# handler selected by data header
handler = self.handler
# how to do run async handler?
loop = asyncio.get_event_loop()
c = handler(data, addr) #coroutine
f = asyncio.ensure_future(c,loop=loop) #attach coroutine to loop
f.add_done_callback(self.respond)
# How to get response here?
# i cant loop.run_until_complete(...) because loop.run_forever() running
#def wakeup():
# pass
#loop.call_soon(wakeup)
# without this call_soon future is not executed in first programm code, but works in test and after refactor
def main(HOST,PORT):
loop = asyncio.get_event_loop()
t = asyncio.Task(loop.create_datagram_endpoint(
Protocol, local_addr=(HOST,PORT)))
transport, server = loop.run_until_complete(t)
sock = transport.get_extra_info('socket')
# socket tuning here
try:
loop.run_forever()
finally:
transport.close()
loop.close()
logging.basicConfig(level=logging.DEBUG)
main('0.0.0.0',10012)
Используйте netcat для проверки nc -u 127.0.0.1 10012
coroutinedocs.python .org/3/library/asyncio-queue.html#asyncio.Queue.get 26.10.2016