python 3.6 coroutine n'a jamais été attendu

Donc quand je lance mon programme et de vous y connecter avec l'écho du client, il me donne cette erreur. 

Starting server
Serving on ('127.0.0.1', 8881)
Exception in callback UVTransport._call_connection_made
handle: <Handle UVTransport._call_connection_made>
Traceback (most recent call last):
File "uvloop/cbhandles.pyx", line 52, in uvloop.loop.Handle._run (uvloop/loop.c:48414)
File "uvloop/handles/tcp.pyx", line 141, in uvloop.loop.TCPTransport._call_connection_made (uvloop/loop.c:80488)
File "uvloop/handles/basetransport.pyx", line 140, in uvloop.loop.UVBaseTransport._call_connection_made (uvloop/loop.c:65774)
File "uvloop/handles/basetransport.pyx", line 137, in uvloop.loop.UVBaseTransport._call_connection_made (uvloop/loop.c:65671)
AttributeError: 'coroutine' object has no attribute 'connection_made'
/home/kenton/Programming/bridal/bridal-middle/middle/lib/server.py:16:RuntimeWarning: coroutine 'handle_request' was never awaited
loop.run_forever()

Pour autant que je sais que j'ai tout ce qui devrait être attendu attendu.
Voici le code:

class Server:
def __init__(self, port):
asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
loop = asyncio.get_event_loop()
server = loop.run_until_complete(self.init(loop))
print("Serving on {}".format(server.sockets[0].getsockname()))
try:
loop.run_forever()
except KeyboardInterrupt:
print("\rclosing the server")
pass
server.close()
loop.run_until_complete(server.wait_closed())
loop.close()
async def init(self, loop):
server = await loop.create_server(self.handle_request, '127.0.0.1', 8881)
return server
async def handle_request(self):
print(datetime.datetime.now())
reader = asyncio.StreamReader()
writer = asyncio.StreamWriter()
data = await reader.read(100)
message = data.decode()
addr = writer.get_extra_info('peername')
code = message.partition('-')
if code[0].startswith("1") or code[0].startswith("5"):
accounts = lib.settings.database.accounts
if code[0] == "101":
result = await self.login_101(code, accounts, writer)
if code[0] == "501":
result = await accounts.find_one({"username":code[2]})
print("looking up", code[0])
#code logic to keep asking for a valid username if one exists
if result is None:
username = code[2]
print(username, " does not exist. Creating")
writer.write(b"0")
await writer.drain()
data = await reader.read(100)
message = data.decode()
code = message.partition('-')
post = {"username":username,"password":code[0],"email":code[2]}
post_id = await accounts.insert_one(post).inserted_id
writer.write(b(post_id))
await writer.drain()
print("Closed the client socket")
writer.close()
print(datetime.datetime.now())
  • Votre indentation semble foiré. Fixer que le premier.
  • Il s'exécute jusqu'à ce qu'elle appelle la méthode handle_request. Si l'indentation est foiré pouvez-vous l'indiquer?
  • La plupart des corps de __init__ est en retrait de mal, par exemple.
InformationsquelleAutor Kenton | 2017-03-30
  1. 2

    Sujet de votre message d'erreur, l'erreur est:

    AttributeError: 'coroutine' object has no attribute 'connection_made'

    Et la ligne ci-dessous est juste un avertissement (RuntimeWarning: coroutine 'handle_request' was never awaited).

    Vous pourriez être un mélange asyncio.start_server avec loop.create_server().

    de la boucle.create_server()'s le premier paramètre est protocol_factory qui est un callable qui retourne une instance d'un Protocol (et pas une coroutine comme dans le code ci-dessus):

    import asyncio
class MyProtocol(asyncio.Protocol):
def connection_made(self, transport):
print("Connection made", transport)
def data_received(self, data):
print("Data received", data)
loop = asyncio.get_event_loop()
# Each client connection will create a new protocol instance
coro = loop.create_server(MyProtocol, '127.0.0.1', 8888)
server = loop.run_until_complete(coro)
loop.run_forever()

    Voir plein echo server exemple ici.

    • Merci cela m'a fait tous ensemble. Je me demandais juste si ces fonctions (data_received et connection_made) exécution asynchrone. Je sais que, normalement, vous devez ajouter async avant que la fonction delaration pour le rendre asynchrone, donc je me demandais si ce sont des?
    InformationsquelleAutor Udi