UDPサーバー内からasyncio.sleepが機能しない

Question

私はasyncio UDP server exampleで遊んでおり、datagram_receivedの方法からsleepを取得したいと考えています。

import asyncio 

class EchoServerProtocol: 
    def connection_made(self, transport): 
     self.transport = transport 

    def datagram_received(self, data, addr): 
     message = data.decode() 
     print('Received %r from %s' % (message, addr)) 
     # Sleep 
     await asyncio.sleep(1) 
     print('Send %r to %s' % (message, addr)) 
     self.transport.sendto(data, addr) 

loop = asyncio.get_event_loop() 
print("Starting UDP server") 
# One protocol instance will be created to serve all client requests 
listen = loop.create_datagram_endpoint(EchoServerProtocol, 
             local_addr=('127.0.0.1', 9999)) 
transport, protocol = loop.run_until_complete(listen) 

try: 
    loop.run_forever() 
except KeyboardInterrupt: 
    pass 

transport.close() 
loop.close() 

これはスリープライン（Python 3.5.1）のSyntaxErrorで失敗します。 time.sleepを使用すると、他のデータグラムの受信を妨げるので、明らかに機能しません。これを解決する方法のヒント？

この目標は、sleepを実際のノンブロッキングI/Oコールに置き換えることです。

Answer 1

awaitはasync def（コルーチン）に住んでいるようです。これを行うには、asyncio.ensure_futureで通話を開始する必要があります。

def datagram_received(self, data, addr): 
    asyncio.ensure_future(self.reply(data, addr)) 

async def reply(self, data, addr): 
    await asyncio.sleep(1) 
    self.transport.sendto(data, addr)