Paramiko 在 psql 上执行命令答案

【问题标题】：Paramiko execute command on psqlParamiko 在 psql 上执行命令
【发布时间】：2018-12-14 14:45:50
【问题描述】：

我正在使用 Paramiko 创建一个连接到我的远程计算机的 ssh，然后我调用 exec_command 来运行以下命令：

psql usera

通常exec_command 返回一个由stdin、stdout 和stderr 组成的元组。所以，我用stdin写CREATE DATABASE X，最后加上'\n'来模拟回车键。该命令需要很长时间，以至于看起来像是卡住了。

这是我的代码：

stdin, stdout, stderr = self.ssh.exec_command('psql usera')
print('executed')
print(stdin)
print(stdout)
print(stderr)
for err in stderr:
    print(err)
for std in stdout:
    print(std)
stdin.write('CREATE DATABASE ' + db_name + ';\n')

此代码将打印以下内容：

executed
<paramiko.ChannelFile from <paramiko.Channel 2 (open) window=2097152 -> <paramik
o.Transport at 0x36a29b0 (cipher aes128-ctr, 128 bits) (active; 3 open channel(s
))>>>
<paramiko.ChannelFile from <paramiko.Channel 2 (open) window=2097152 -> <paramik
o.Transport at 0x36a29b0 (cipher aes128-ctr, 128 bits) (active; 3 open channel(s
))>>>
<paramiko.ChannelFile from <paramiko.Channel 2 (open) window=2097152 -> <paramik
o.Transport at 0x36a29b0 (cipher aes128-ctr, 128 bits) (active; 3 open channel(s
))>>>
2018-12-12 19:22:39; DEBUG; EOF in transport thread

这意味着代码没有执行stdin.write()。这是启动命令和在提示符下启动命令的正确方法吗？

【问题讨论】：

@MartinPrikryl ，在 stdin, stdout, stderr = self.ssh.exec_command('psql usera') 之后卡住了
好吧：stdin，stdout，stderr = self.ssh.exec_command('psql usera') print('executed !') print(stdin) print(stdout) print(stderr) for err in stderr: self.logger.error(err) for std in stdout: print(std) print('ex') print('2') 将显示 => 已执行！ >> 3并发打印。
好的，完成了！

标签： python shell ssh psql paramiko

【解决方案1】：

您尝试在发送 SQL 命令之前读取命令输出。你的循环等待命令完成，它永远不会做，因为它一直在等待输入。这是一个僵局。

它必须是相反的方式：

stdin.write('CREATE DATABASE ' + db_name + ';\n')
for err in stderr:
    print(err)
for std in stdout:
    print(std)

虽然我不熟悉psql 命令行，但我很确定上面的代码也会挂起，因为在CREATE DATABASE、psql 之后它可能会继续等待另一个命令。您需要添加类似EXIT 的内容。或致电stdin.close()。

stdin.write('CREATE DATABASE ' + db_name + ';\n')
stdin.close()
for err in stderr:
    print(err)
for std in stdout:
    print(std)

【讨论】：