- #!/usr/bin/env python
- #coding:utf8
- import os,sys
- import md5,tab
- from mysql_co.my_db import set_mysql
- from ssh_co.ssh_connect import sshd
- from ssh_co.cfg.config import ssh_message,item_path
- from file import findfile
- def my_mysql():
- db_file={}
- my_connect=set_mysql()
- f_file=findfile.main(item_path)
- list_file=findfile.file_list(f_file)
- see_file=my_connect.display_db()
- for knumber,kname,ksgin,ksize,katime,kmtime in see_file:
- db_file[kname]=[ksgin,ksize,katime,kmtime]
- for fname,fsize,fatime,fmtime in list_file:
- if fname in db_file.keys():
- if ("%f")%fmtime == ("%f")%db_file[fname][3]:
- print "%s The same mtime pass"%fname
- my_connect.set_file_attribute(10,fname,fmtime)
- pass
- else:
- print "%s different for mtime"%fname
- my_connect.set_file_attribute(11,fname,fmtime)
- else:
- my_connect.add_db(fname,fsize,fatime,fmtime)
- my_connect.set_file_attribute(11,fname,fmtime)
- print "%s,is new file"%fname
- new_file=my_connect.new_db()
- my_connect.disconn_db()
- return new_file
- def my_ssh(new_file):
- pid_host = 1
- for host_attribute in ssh_message:
- ssh_conn=sshd(host_attribute,pid_host)
- for file_name in new_file:
- if file_name:
- a=ssh_conn.put_ssh_file(file_name[1])
- print a
- print "ssh_connect memoryID: %s" %pid_host
- else:
- pid_host = id(host_attribute)
- ssh_conn.disconn_ssh()
- def main():
- new_file=my_mysql()
- my_ssh(new_file)
- if __name__ == "__main__":
- main()
- #该片段来自于http://www.codesnippet.cn/detail/290420149406.html
来源: http://www.codesnippet.cn/detail/290420149406.html