- 导入paramiko库,paramiko是一个基于SSH用于连接远程服务器并执行相关操作的库
- 建立连接,在本地将命令传送给远程机,对指定docker容器进行操作
- 文件传输,关闭连接
因为这两种都可是实现连接远程机,自己初学时网上的介绍一般都是把实现命令和文件传输分开介绍。在这里就不单独介绍这两种了,直接说一下建立简介后同时需要发送命令和文件操作的需求情况,有单独的需求可以查找其他博主的详细介绍
代码 SSHClient是传统的连接服务器、执行命令、关闭的一个操作,而transport 方式登录后可以实现文件等操作,这里的方法就是把paramiko.Transport创建的连接赋给SSHClient连接对象ssh,使得ssh可以同时发送命令和文件操作。
docker操作:需要熟悉docker命令,比如
docker ps # 列出docker容器
docker exec # 进入容器,可通过容器id和容器名称进入
注意使用docker exec进入容器时要考虑工作目录切换问题,一般接上‘-it’参数后在命令行可以进入docker继续输入命令,然而使用ssh.exec_command发送docker exec -it会报错,因为此时并不需要可交互的方式,可去掉-it参数
在这里需要继续进入目录和下载,去掉-it参数同时也无法继续操作,可直接通过命令暂时缓存到远程机,后续从远程机下载就方便了
docker cp 容器名称:文件路径 目标路径
class Download:
def __init__(self, ip, username, password):
self.ip = ip # 远程机ip,
self.username = username
self.password = password
def download_logs(self):
ssh = paramiko.SSHClient() # 创建ssh对象
t = paramiko.Transport(self.ip, 22) # 指定远程机地址、端口
t.connect(username=self.username, password=self.password) # 连接服务器
ssh._transport = t # 将创建的连接赋给连接对象ssh
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 允许连接不在know_hosts文件中的主机
ssh.exec_command('docker cp apitest_executor_XXX:/home/downloads/ /home/downloads') # 将docker容器的文件缓存到执行机目录中
# 接下来将远程机缓存目录文件下载到本地
sftp = paramiko.SFTPClient.from_transport(t) # 建立sftp文件传输服务
time.sleep(5) # 这里要注意程序的执行速度差,下面有解释
sftp.get(remote_file, local_file) # 下载
ssh.exec_command('rm -rf ' + remote_path) # 删除远程机缓存文件
ssh.close() # 关闭连接
一些小问题:
- 由于程序发送指令和远程机执行指令所花费的时间不一致,需要考虑双方速度差,否则可能会出现文件不全的情况,比如当docker中的文件比较大时,程序发送了
ssh.exec_command('docker cp apitest_executor_XXX:/home/downloads/ /home/downloads')
指令后,会马上执行下一条,而远程机复制需要一段时间,因此需要等待或判断下文件数量 - sftp.get()只能每次传输单个文件,多级目录下可以配合sftp.listdir()使用



