145 lines
5.2 KiB
Python
145 lines
5.2 KiB
Python
# -*- coding:utf-8 -*-
|
|
#############################################################################
|
|
# Copyright (c) 2020 Huawei Technologies Co.,Ltd.
|
|
#
|
|
# openGauss is licensed under Mulan PSL v2.
|
|
# You can use this software according to the terms
|
|
# and conditions of the Mulan PSL v2.
|
|
# You may obtain a copy of Mulan PSL v2 at:
|
|
#
|
|
# http://license.coscl.org.cn/MulanPSL2
|
|
#
|
|
# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OF ANY KIND,
|
|
# EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
|
|
# MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
|
|
# See the Mulan PSL v2 for more details.
|
|
# ----------------------------------------------------------------------------
|
|
# Description : execute local or remote cmd
|
|
#############################################################################
|
|
import os
|
|
import subprocess
|
|
import threading
|
|
|
|
from base_utils.common.constantsbase import ConstantsBase
|
|
from gspylib.common.ErrorCode import ErrorCode
|
|
from base_utils.os.cmd_util import CmdUtil
|
|
from base_utils.os.net_util import NetUtil
|
|
from gspylib.os.gsfile import g_file
|
|
from base_utils.executor.cmd_executor import CmdExecutor
|
|
|
|
|
|
class LocalRemoteCmd(object):
|
|
"""
|
|
execute local or remote cmd
|
|
"""
|
|
|
|
@staticmethod
|
|
def cleanFile(file_name, hostname=""):
|
|
"""
|
|
function : remove file
|
|
input : String,hostname
|
|
output : NA
|
|
"""
|
|
file_list = file_name.split(",")
|
|
|
|
cmd = ""
|
|
for _file_name in file_list:
|
|
delete_cmd = g_file.SHELL_CMD_DICT["deleteFile"] % (_file_name, _file_name)
|
|
if cmd != "":
|
|
cmd += ';%s' % delete_cmd
|
|
else:
|
|
cmd = delete_cmd
|
|
|
|
if "" != hostname and NetUtil.GetHostIpOrName() != hostname:
|
|
cmd = CmdUtil.getSshCommand(hostname, cmd)
|
|
CmdExecutor.execCommandLocally(cmd)
|
|
|
|
@staticmethod
|
|
def cleanFileDir(dir_name, g_ssh_tool=None, hostname=None):
|
|
"""
|
|
function: clean directory or file
|
|
input: dir_name, g_sshTool, hostname
|
|
output:NA
|
|
"""
|
|
cmd = g_file.SHELL_CMD_DICT["deleteDir"] % (dir_name, dir_name)
|
|
# If clean file or directory on local node
|
|
if g_ssh_tool is None:
|
|
(status, output) = subprocess.getstatusoutput(cmd)
|
|
if status != 0:
|
|
raise Exception(ErrorCode.GAUSS_514["GAUSS_51400"] % cmd
|
|
+ "Error:\n%s" % str(output))
|
|
else:
|
|
# Assign some remote node to clean directory or file.
|
|
if not hostname:
|
|
g_ssh_tool.executeCommand(cmd)
|
|
else:
|
|
g_ssh_tool.executeCommand(cmd, ConstantsBase.SUCCESS, hostname)
|
|
|
|
@staticmethod
|
|
def scpFile(ip, source_path, target_path, copy_to=True):
|
|
"""
|
|
function : if copyTo is True, scp files to remote host else,
|
|
scp files to local host
|
|
input : destination host ip
|
|
source path
|
|
target path
|
|
copyTo
|
|
output: NA
|
|
"""
|
|
scp_cmd = ""
|
|
if os.path.isdir(source_path):
|
|
scp_cmd = LocalRemoteCmd.getRemoteCopyCmd(
|
|
source_path, target_path, ip, copy_to, "directory")
|
|
elif os.path.exists(source_path):
|
|
scp_cmd = LocalRemoteCmd.getRemoteCopyCmd(
|
|
source_path, target_path, ip, copy_to)
|
|
|
|
(status, output) = subprocess.getstatusoutput(scp_cmd)
|
|
# if cmd failed, then exit
|
|
if status != 0:
|
|
raise Exception(ErrorCode.GAUSS_514["GAUSS_51400"] % scp_cmd +
|
|
" Error:\n%s" % output)
|
|
|
|
@staticmethod
|
|
def checkRemoteDir(g_ssh_tool, remote_dir, hostname, mpprc_file="", local_mode=False):
|
|
'''
|
|
function: check the remoteDir is existing on hostname
|
|
input: remoteDir, hostname, mpprcFile
|
|
output:NA
|
|
'''
|
|
# check package dir
|
|
# package path permission can not change to 750, or it will have permission issue.
|
|
toolpath = remote_dir.split("/")
|
|
toolpath[0] = "/" + toolpath[0]
|
|
pathcmd = ""
|
|
for path in toolpath:
|
|
if path == "":
|
|
continue
|
|
cmd = g_file.SHELL_CMD_DICT["createDir"] % (
|
|
path, path, ConstantsBase.MAX_DIRECTORY_MODE)
|
|
pathcmd += "%s; cd '%s';" % (cmd, path)
|
|
pathcmd = pathcmd[:-1]
|
|
CmdExecutor.execCommandWithMode(pathcmd,
|
|
g_ssh_tool, local_mode, mpprc_file, hostname)
|
|
|
|
@staticmethod
|
|
def getRemoteCopyCmd(src, dest, remote_host, copy_to=True,
|
|
path_type="", other_host=None):
|
|
"""get pssh pscp cmd"""
|
|
opts = ""
|
|
trace_id = threading.currentThread().getName()
|
|
|
|
if path_type == "directory":
|
|
opts = "-x -r"
|
|
if copy_to:
|
|
return "pscp --trace-id %s %s -H %s %s %s " % \
|
|
(trace_id, opts.strip(), remote_host, src, dest)
|
|
else:
|
|
localhost = NetUtil.getLocalIp()
|
|
if other_host is not None:
|
|
localhost = other_host
|
|
return "pssh --trace-id %s -s -H %s \" pscp --trace-id %s %s -H %s %s %s \" " % \
|
|
(trace_id, remote_host, trace_id, opts.strip(), localhost, src, dest)
|
|
|