first

joe011 · joe011 · commit e2e2dc17d422 · 2013-08-07T14:24:11.000+08:00
diff --git a/remote_cmd.py b/remote_cmd.py
@@ -0,0 +1,41 @@
+#!/usr/bin/python
+#coding:utf-8
+import paramiko
+import sys
+import datetime
+
+if len(sys.argv) < 2 :
+	print "\033[41mPlease input iplist and cmd,like  'python remote_cmd.py iplist ls'\033[0m"
+	sys.exit()
+iplist=sys.argv[1]
+cmd=sys.argv[2]
+now=datetime.datetime.now()
+file=open(iplist)
+
+for l in file.readlines():
+    	if  len(l)==1 or  l.startswith('#'):
+        	continue
+#	print l,
+	f=l.split()
+	#print f
+	hostip=f[0]
+	username=f[1]
+	password=f[2]
+	port=f[3]
+        print "\033[42m---------------------------------%s---------------------------\033[0m" %hostip
+	try:
+        	#paramiko.util.log_to_file('ssh.log')
+        	s=paramiko.SSHClient()
+       	 	s.load_system_host_keys()
+        	s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
+       		s.connect(hostname=hostip,port=port,username=username, password=password)
+        	stdin,stdout,stderr=s.exec_command(cmd)
+		print	 stdout.read()
+        	s.close()
+	except Exception,ex:
+                print "\n",hostip,":\t",ex,"\n"
+		ssh_errors=open("ssh_errors.log","a")
+		ssh_errors.write("%s\t%s:\t%s\n"%(now,hostip,ex))
+		ssh_errors.close()
+                pass
+file.close()
diff --git a/remote_file.py b/remote_file.py
@@ -0,0 +1,44 @@
+#!/usr/bin/python
+import paramiko 
+import sys
+import datetime
+
+
+if len(sys.argv) < 2 :
+	print '\033[41mPlease input iplist and command,like  "python remote_cmd.py iplist upload_filename"\033[0m'
+	sys.exit()
+
+iplist=sys.argv[1]
+local_dir=sys.argv[2]
+remote_dir='/tmp/'+local_dir
+now=datetime.datetime.now()
+
+file=open(iplist,'r')
+
+if __name__  ==  "__main__" :
+	for l in file.readlines():
+		if  len(l)== 1 or  l.startswith('#'):
+			continue
+       		f=l.split()
+		hostip=(f[0])
+      		username=(f[1])
+     		password=(f[2])
+		port=int(f[3])
+#		print type(port)
+#		paramiko.util.log_to_file('sftp.log')
+		try:
+			t=paramiko.Transport((hostip,port))
+			t.connect(username=username,password=password) 
+			sftp=paramiko.SFTPClient.from_transport(t) 
+			sftp.put(local_dir,remote_dir)
+			print "Upload file \033[31m%s\033[0m to \033[32m%s\033[0m:\033[33m%s\033[0m : %s" %(local_dir,hostip,remote_dir,now)
+			sftp.close()
+			t.close()
+	        except Exception,ex:
+               		print "\n",hostip,":\t",ex,"\n"
+                	ssh_errors=open("ssh_errors.log","a")
+                	ssh_errors.write("%s\t%s:\t%s\n"%(now,hostip,ex))
+                	ssh_errors.close()
+                	pass
+
+file.close()
