1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
#!/usr/bin/env python
#-*-coding:UTF-8-*-
"""
@Item   :  v1.0
@Author :  ShengWangQiang
@Group  :  System 
@Date   :  2015-01-28
@E-mail :  swq.499809608@hotmail.com
@Funtion:
          
"""
 
import sys,time,os,traceback,commands,
import paramiko,
 
class Remote(object):
    def __init__(self):
        version = 'v0.1'
        self.users = 'root'
        self.passwd  = "1234567890"
        self.port = 22
         
 
    def log(self,info):
        files = open('/tmp/deploy.log','a')
        try:
            files.write('[%s]: %s \n' %(time.ctime(),info))
        except IOError:
            files.close()
        files.close()
 
 
    def cmds(self,host,comm):
        try:
            print comm
            client = paramiko.Transport((host,int(self.port)))
            client.connect(username=self.users,password=self.passwd)
            chan = client.open_session()
            chan.exec_command(comm)
            chan.close()
        except:
            print 'host', host
            print traceback.format_exc()
            self.log(traceback.format_exc())
 
    def sftps(self,host,files):
        try:
            lodir = '/opt/onfile'
            rmdir = '/opt/onfile'
            client = paramiko.Transport((host,int(self.port)))
            client.connect(username=self.users,password=self.passwd)
            sftp = paramiko.SFTPClient.from_transport(client)
            sftp.put('%s/%s'%(lodir,files),'%s/%s'%(rmdir,files))
            client.close()
        except:
            print traceback.format_exc()
            self.log(traceback.format_exc())
 
    def work(self,comm):
        fp = open('/opt/online/ser_list.txt').readlines()
        for s in fp:
            host = s.strip()
            self.cmds(host,comm)
    def sftp(self,comm):
        fp = open('/opt/online/ser_list.txt').readlines()
        for s in fp:
            host = s.strip()
            self.sftps(host,files)
 
if __name__ == '__main__':
    sc = Remote()
    func =  sys.argv[1]
    files = sys.argv[2]
    if func == 'sftp':
        sc.sftp(files)
    elif func == 'work':
        sc.work(files)