此脚本功能主要是找到/data1到/data11下面在当前时间一天以外的所有文件,并复制到另外一台新机器上面。

注意:重点检验自动化交互输入密码,进行远程文件复制功能

#!/usr/bin/pyth
#coding=utf-8  #字符编码
import os  #os模块
import pexpect #自动交互模块
import time #导入时间模块
dir_name=os.popen("ls -l / |grep ‘data[0-9]\{1,2\}‘|awk ‘{print $NF}‘").readlines() #统计/data后面带有数字的目录,例/data1-11
def cp_file():  #scp复制文件函数
    global jindu              #定义全局变量,jindu
    file_order=‘scp -oStrictHostKeyChecking=no %s %s@%s:%s‘ %(fullname,user,add_ip,dirname)  #执行scp复制命令
    # -oStrictHostKeyChecking=no",用来避免 输入第一次 执行ssh 要求收入yes/no 用的
    scp_file=pexpect.spawn(file_order,timeout=100000) #执行pexpect的spawn方法
    scp_file.expect(‘password:‘)       #自动交互匹配password关键字
    scp_file.sendline(password)        #自动匹配成功后,进行密码发送
    scp_file.read()                    #这个参数我在百度查询的,如果不加就复制不成功
    jindu=scp_file.before.split()[-4]  #判断复制文件是否成功,根据进度调进行判断,如果进度调为100%,表示成功.
    scp_file.close()                   #进行关闭
for dir_line in  dir_name: #对dir_name进行匹配
    mulu=dir_line.strip()  #去掉两边空格,进行赋值
    find_file="find /%s -type f  -mtime +1|xargs ls -l" %mulu #判断当前时间1天以外的所有数据
    return_file=os.popen(find_file).readlines()     #执行shell程序,并把结果赋值到retrun_file变量
    mulu_list=[]                               #存放目录的列表
    for file_line in return_file:              #对第一个目录进行循环
        fullname=file_line.strip().split()[8]  #取出文件全路径名
        dirname=os.path.dirname(file_line.strip()).split()[8] #取出目录名字
        scp_file_success=file(‘/tmp/scp_file_success.log‘,‘a‘) #同步复制成功写入日志
        scp_file_fail=file(‘/tmp/scp_file_fail.log‘,‘a‘)       #同步复制失败写入日志 
        now_time=time.strftime(‘%Y%m%d %H:%M:%S‘,time.localtime(time.time()))#复制文件当前时间
        log_success=‘%s %s 文件同步成功!\n‘ %(now_time,fullname) #成功日志显示
        log_fail=‘%s %s 文件同步失败!\n‘    %(now_time,fullname) #失败日志显示
        local_fail=‘%s %s 本地文件不存在!\n‘    %(now_time,fullname) #检查本地文件是否存在
        add_ip="192.168.3.1"       #新cache节点ip
        user="root"                  #新cache节点用户
        password="123"            #新cache节点密码
        if os.path.isfile(fullname)==True: #判断旧节点拷贝文件是否存在,如果存在就继续执行,如果不存在写日志记录,继续循环
           if dirname not in mulu_list: #判断目录是否存在mulu_list列表,如果不存在,则到新节点先创建目录,再复制文件
              mkdir_order=‘mkdir -p %s‘ %dirname  #新建目录用到的权限
              ssh_server="ssh -oStrictHostKeyChecking=no %s ‘%s‘" %(add_ip,mkdir_order) #执行ssh登陆脚本
              create_directory=pexpect.spawn(ssh_server)   #执行pexpect的spawn方法,ssh登陆
              create_directory.expect(‘password:‘)         #自动交互匹配password关键字
              create_directory.sendline(password)          #自动匹配成功后,进行密码发送
              create_directory.read()                      #这个参数我在百度查询的,如果不加就复制不成功
              create_directory.close()                     #进行关闭
              mulu_list.append(dirname)                    #创建成功的目录添加到列表
              cp_file()                                    #执行文件复制方法
              if jindu=="100%":                            #判断复制文件是否成功,根据进度调进行判断,如果进度调为100%,表示成功.
                 scp_file_success.write(log_success) 
              else:
                 scp_file_fail.write(log_fail)
           else:   #v如果新节点目录存在则直接拷贝文件
               cp_file()                                    #执行文件复制方法
               if jindu=="100%":                            #判断复制文件是否成功,根据进度调进行判断,如果进度调为100%,表示成功.
                  scp_file_success.write(log_success)
               else:
                  scp_file_fail.write(log_fail)
        else:
           scp_file_fail.write(local_fail)
    del mulu_list[:]    #每次循环一个data目录就清空列表
scp_file_success.close() #日志关闭
scp_file_fail.close()    #日志关闭

本文出自 “成都@阿状” 博客，请务必保留此出处http://azhuang.blog.51cto.com/9176790/1606159

自动化交互输入密码,进行远程文件复制