Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import time
- import subprocess
- from watchdog.observers import Observer
- from watchdog.events import FileSystemEventHandler
- class NewFile(FileSystemEventHandler):
- def process(self, event):
- if event.is_directory:
- return
- if event.event_type == 'modified':
- if getext(event.src_path) == 'gz':
- load_pgdump(event.src_path)
- def on_modified(self, event):
- self.process(event)
- def getext(filename):
- "Get the file extension"
- file_ext = filename.split(".",1)[1]
- return file_ext
- def load_pgdump(src_path):
- restore = 'pg_restore command ' + src_path
- subprocess.call(restore, shell=True)
- def main():
- event_handler = NewFile()
- observer = Observer()
- observer.schedule(event_handler, path='Y:\', recursive=True)
- observer.start()
- try:
- while True:
- time.sleep(1)
- except KeyboardInterrupt:
- observer.stop()
- observer.join()
- if __name__ == '__main__':
- main()
- historicalSize = -1
- while (historicalSize != os.path.getsize(filename)):
- historicalSize = os.path.getsize(filename)
- time.sleep(1)
- print "file copy has now finished"
- copying = True
- size2 = -1
- while copying:
- size = os.path.getsize('name of file being copied')
- if size == size2:
- break
- else:
- size2 = os.path.getsize('name of file being copied')
- time.sleep(2)
- past = 0
- now = 1
- value = [past, now]
- while True:
- # change
- # test
- if value[0] == value[1]:
- break
- else:
- value = [value[1], value[0]]
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement