import paramiko
import time


def ssh_tran(address, user, passwd, port, cmd):
    tran = paramiko.Transport((address, int(port)))
    tran.start_client()
    tran.auth_password(user, passwd)

    chan = tran.open_session()
    chan.get_pty()
    chan.exec_command(cmd)  # 执行命令，而不是invoke_shell()

    while True:
        print(chan.recv_ready())
        if chan.recv_ready():  # 检查通道是否准备好接收数据
            output = chan.recv(4096)  # 读取数据
            if output:
                print(output.decode())
            else:
                break  # 如果没有数据，可能通道已关闭，退出循环
        time.sleep(0.1)  # 休眠0.1秒，避免忙等待

    chan.close()
    tran.close()


# 使用函数
ssh_tran("192.168.0.150", "root", "Cyberark1", "22", "whoami")