在 Python 中在远程机器上执行命令

Question

我正在 Ubuntu 上的 python 中编写程序，以在 RaspberryPi 上执行命令 ls -l，连接网络。

谁能指导我该怎么做？

Answer 1

当然，有几种方法可以做到！

假设您在 raspberry.lan 主机上有一个 Raspberry Pi，您的用户名是 irfan。

子进程

这是运行s 命令的默认 Python 库。
您可以将其设置为运行 ssh 并在远程服务器上执行任何您需要的操作。

scrat 。如果您不想使用任何第三方库，您绝对应该这样做。

您还可以使用 pexpect.

自动输入 password/passphrase

帕拉米科

paramiko 是添加 SSH 协议支持的第三方库，因此它可以像 SSH 客户端一样工作。

连接到服务器、执行并获取 ls -l 命令结果的示例代码如下所示：

import paramiko

client = paramiko.SSHClient()
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
client.connect('raspberry.lan', username='irfan', password='my_strong_password')

stdin, stdout, stderr = client.exec_command('ls -l')

for line in stdout:
    print line.strip('\n')

client.close()

面料

您也可以使用 fabric 来实现它。
Fabric 是一个在远程服务器上执行各种命令的部署工具。

它通常用于运行远程服务器上的东西，因此您可以轻松地放置最新版本的网络应用程序、重新启动网络服务器以及诸如此类的单个命令。实际上，您可以运行在多个服务器上使用相同的命令，这太棒了！

虽然它是作为部署和远程管理工具制作的，但您仍然可以使用它来执行基本命令。

# fabfile.py
from fabric.api import *

def list_files():
    with cd('/'):  # change the directory to '/'
        result = run('ls -l')  # run a 'ls -l' command
        # you can do something with the result here,
        # though it will still be displayed in fabric itself.

这就像在远程服务器中键入 cd / 和 ls -l，因此您将获得根文件夹中的目录列表。

然后运行在 shell:

fab list_files

它会提示输入服务器地址：

No hosts found. Please specify (single) host string for connection: irfan@raspberry.lan

快速说明：您还可以在 fab 命令中分配用户名和主机权限：

fab list_files -U irfan -H raspberry.lan

或者您可以将主机放入 fab 文件中的 env.hosts 变量中。 Here's how to do it.

然后系统会提示您输入 SSH 密码：

[irfan@raspberry.lan] run: ls -l
[irfan@raspberry.lan] Login password for 'irfan':

然后命令将运行成功。

[irfan@raspberry.lan] out: total 84
[irfan@raspberry.lan] out: drwxr-xr-x   2 root root  4096 Feb  9 05:54 bin
[irfan@raspberry.lan] out: drwxr-xr-x   3 root root  4096 Dec 19 08:19 boot
...

Answer 2

来自 here 的简单示例：

import subprocess
import sys

HOST="www.example.org"
# Ports are handled in ~/.ssh/config since we use OpenSSH
COMMAND="uname -a"

ssh = subprocess.Popen(["ssh", "%s" % HOST, COMMAND],
                       shell=False,
                       stdout=subprocess.PIPE,
                       stderr=subprocess.PIPE)
result = ssh.stdout.readlines()
if result == []:
    error = ssh.stderr.readlines()
    print >>sys.stderr, "ERROR: %s" % error
else:
    print result

它完全符合您的要求：通过 ssh 连接，执行命令，returns 输出。不需要第三方库。

Answer 3

您可以使用以下方法与 linux/ Unix 内置的 ssh 命令。

   import os
   os.system('ssh username@ip  bash < local_script.sh >> /local/path/output.txt 2>&1')
   os.system('ssh username@ip  python < local_program.py >> /local/path/output.txt 2>&1')

Answer 4

通过调用 shell，Paramiko 模块可用于运行多个命令。这里我创建了 class 来调用 ssh shell

class ShellHandler:

def __init__(self, host, user, psw):
    logger.debug("Initialising instance of ShellHandler host:{0}".format(host))
    try:
        self.ssh = paramiko.SSHClient()
        self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        self.ssh.connect(host, username=user, password=psw, port=22)
        self.channel = self.ssh.invoke_shell()
    except:
        logger.error("Error Creating ssh connection to {0}".format(host))
        logger.error("Exiting ShellHandler")
        return
    self.psw=psw
    self.stdin = self.channel.makefile('wb')
    self.stdout = self.channel.makefile('r')
    self.host=host
    time.sleep(2)

    while not self.channel.recv_ready():
        time.sleep(2)
    self.initialprompt=""
    while self.channel.recv_ready():

        rl, wl, xl = select.select([ self.stdout.channel ], [ ], [ ], 0.0)
        if len(rl) > 0:
            tmp = self.stdout.channel.recv(24)
            self.initialprompt=self.initialprompt+str(tmp.decode())



def __del__(self):
    self.ssh.close()
    logger.info("closed connection to {0}".format(self.host))

def execute(self, cmd):
    cmd = cmd.strip('\n')
    self.stdin.write(cmd + '\n')
    #self.stdin.write(self.psw +'\n')
    self.stdin.flush()
    time.sleep(1)
    while not self.stdout.channel.recv_ready():
        time.sleep(2)
        logger.debug("Waiting for recv_ready")

    output=""
    while self.channel.recv_ready():
        rl, wl, xl = select.select([ self.stdout.channel ], [ ], [ ], 0.0)
        if len(rl) > 0:
            tmp = self.stdout.channel.recv(24)
            output=output+str(tmp.decode())
    return output

如果每次创建不同的 shell 对您来说并不重要，那么您可以使用以下方法。

def run_cmd(self,cmd):
    try:
        cmd=cmd+'\n'
        #self.ssh.settimeout(60)
        stdin,stdout,stderr=self.ssh.exec_command(cmd)
        while not stdout.channel.eof_received:
           time.sleep(3)
           logger.debug("Waiting for eof_received")
        out=""
        while stdout.channel.recv_ready():
            err=stderr.read()
            if err:
                print("Error: ",my_hostname, str(err))
                return False 

            out=out+stdout.read()
        if out:
               return out 

    except:
        error=sys.exc_info()
        logger.error(error)
        return False

在 Python 中在远程机器上执行命令

Execute a command on Remote Machine in Python

python

terminal

ubuntu

tkinter

paramiko

子进程

帕拉米科

面料