python遠端執行

python paramiko 模組的應用

環境

# yum install python-dev
# yum install python-devel
# pip install pycrypto
# pip install paramiko
# pip install ssh

方法體

import paramiko
def DiskCheck(ip):
    try:
        # 建立一個sshclient物件
        ssh = paramiko.SSHClient()
        # 允許將信任的主機自動加入到host_allow 列表，此方法必須放在connect方法的前面
 

        ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        # 指定本地的RSA私鑰檔案,如果建立金鑰對時設定的有密碼，password為設定的密碼，如無不用指定password引數
        # pkey = paramiko.RSAKey.from_private_key_file('/home/super/.ssh/id_rsa', password='12345')
        pkey = paramiko.RSAKey.from_private_key_file('/home/ptop/topicjie/scripts/keys/id_rsa'
 
)
        # 建立連線
        ssh.connect(hostname=ip,
                    port=22,
                    username='ptop',
                    pkey=pkey)
        # 執行命令
        stdin, stdout, stderr = ssh.exec_command("for i in $(df -h|grep data|awk '{print $6}'); do  touch $i/test.txt; done; df -h|grep data"
 
)
        # 結果放到stdout中，如果有錯誤將放到stderr中
        print(stdout.read().decode())
        print(stderr.read())
        # 關閉連線
        ssh.close()

提示：最好採用ssh免祕鑰登入的模式，儘量不要出現明文密碼

本機執行shell指令碼

python中有很多呼叫本地shell指令碼的方法 類似commands 等，不過現在官方推薦的是使用subprocess 進行本地shell指令碼的呼叫，這個模組的方法較多。

import shlex
import subprocess

def execute_command(cmdstring, cwd=None, timeout=None, shell=False):
    if shell:
        cmdstring_list = cmdstring
    else:
         cmdstring_list = shlex.split(cmdstring)
    if timeout:
        end_time = datetime.datetime.now() + datetime.timedelta(seconds=timeout)
        #沒有指定標準輸出和錯誤輸出的管道，因此會列印到螢幕上；
    sub = subprocess.Popen(cmdstring_list, cwd=cwd, stdin=subprocess.PIPE,shell=shell,bufsize=4096)
    #subprocess.poll()方法：檢查子程序是否結束了，如果結束了，設定並返回碼，放在subprocess.returncode變數中 
    while sub.poll() is None:
        time.sleep(0.1)
        if timeout:
            if end_time <= datetime.datetime.now():
                raise Exception("Timeout：%s"%cmdstring)

    return str(sub.returncode)
#方法測試
p=execute_command("hive -f "+path)