python - TypeError : A Future or coroutine is required

我尝试在asyncssh上进行自动重新连接ssh客户端。 (SshConnectManager必须留在后台并在需要时进行ssh session )

class SshConnectManager(object):
def __init__(self, host, username, password, port=22):
    self._host = host
    self._username = username
    self._password = password
    self._port = port

    self.conn = None
    asyncio.async(self.start_connection)

@asyncio.coroutine
def start_connection(self):
    try:
        Client = self._create_ssh_client()
        self.conn, _ = yield from asyncssh.create_connection(Client,
                                                        self._host, port=self._port,
                                                        username=self._username,
                                                        password=self._password)
    except Exception as e:
        print("Connection error! {}".format(e))
        asyncio.async(self.start_connection())

def _create_ssh_client(self):
    class MySSHClient(asyncssh.SSHClient):
        parent = self
        def connection_lost(self, exc):
            self.parent._handle_connection_lost(exc)
    return MySSHClient

def _handle_connection_lost(self, exc):
    print('Connection lost on {}'.format(self.host))
    print(exc)
    asyncio.async(self.start_connection)


ssh1 = SshConnectManager(settings.host, settings.username, settings.password, settings.port)

asyncio.get_event_loop().run_until_complete(...)

请不要看_create_ssh_client或其他“哈希”

问题是:

$ python3 main.py
Traceback (most recent call last):
  File "main.py", line 75, in <module>
    ssh1 = SshConnectManager(settings.host, settings.username, settings.password, settings.port)
  File "main.py", line 22, in __init__
    asyncio.async(self.start_connection)
  File "/usr/lib/python3.4/asyncio/tasks.py", line 565, in async
    raise TypeError('A Future or coroutine is required')
TypeError: A Future or coroutine is required

但是self.start_connection是轻而易举的!或不？
或者从同步代码开始异步任务的另一种方法是什么？

最佳答案

感谢@dano和@boardrider在评论中的帮助。
错误是@ asyncio.coroutine返回函数需要获取生成器对象的函数。我忘记这样做了。

固定版本:

class SshConnectManager(object):
def __init__(self, host, username, password, port=22):
    self._host = host
    self._username = username
    self._password = password
    self._port = port

    self.conn = None
    # FIX HERE
    asyncio.async(self.start_connection())

@asyncio.coroutine
def start_connection(self):
    try:
        Client = self._create_ssh_client()
        self.conn, _ = yield from asyncssh.create_connection(Client,
                                                        self._host, port=self._port,
                                                        username=self._username,
                                                        password=self._password)
    except Exception as e:
        print("Connection error! {}".format(e))
        asyncio.async(self.start_connection())

def _create_ssh_client(self):
    class MySSHClient(asyncssh.SSHClient):
        parent = self
        def connection_lost(self, exc):
            self.parent._handle_connection_lost(exc)
    return MySSHClient

def _handle_connection_lost(self, exc):
    print('Connection lost on {}'.format(self.host))
    print(exc)
    # AND HERE
    asyncio.async(self.start_connection())


ssh1 = SshConnectManager(settings.host, settings.username, settings.password, settings.port)

asyncio.get_event_loop().run_until_complete(...)

P.S.但是我不理解为什么协程装饰器无法返回被称为装饰器的原因。 (这使我感到困惑，我将其与扭曲的回调混淆了)。

而且我发现了如何记住这一点，如果start_connection可以获取参数，则有一个简单的例子:

@asyncio.coroutine
def start_connection(self, some_arg):
    pass

所以，我可以简单地写:

asyncio.async(self.start_connection(some_val))

不需要在asyncio.async函数中添加其他属性

关于python - TypeError : A Future or coroutine is required，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/30450533/