Я пытаюсь вызвать асинхронную функцию из функции синхронизации обратного вызова (обратный вызов Paramiko), но не удастся ⇐ Python

[Anonymous]

Код: Выделить всё

import os
import paramiko
import asyncio

async def async_websocket_call(msg):
print(msg)

async def test_paramiko():
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect("web.demo.net", username="root", key_filename=os.environ['USERPROFILE'] + "\\.ssh\\id_rsa")

def upload_callback(sofar, total):
loop = asyncio.get_running_loop()
task = loop.create_task(async_websocket_call("Uploaded: {0:.1f}%".format(100*(sofar/total))))
asyncio.wait(task, timeout=None)

sftp = ssh.open_sftp()
sftp.put('test.tar.gz', '/var/www/html/test.tar.gz', upload_callback)
sftp.close()

ssh.close()

loop = asyncio.get_event_loop()
loop.run_until_complete(test_paramiko())
loop.close()
< /code>
Я получаю сообщение об ошибке: runtimewarning: coroutine 'wating' никогда не ожидал < /p>
Ну, я не могу дождаться метода ожидания, потому что я не в методе Asyncssh ... < /p>   обновление: < /p>
asyncssh также не является решением, потому что < /p>                          sftp.put использует progress_handler типа sftpprogresshandler: < /p>
SFTPProgressHandler = Optional[Callable[[bytes, bytes, int, int], None]]

Так что это также не поддерживает асинхронные обратные вызовы, кажется.

Подробнее здесь: https://stackoverflow.com/questions/732 ... aramiko-up