前言:

用 python 實(shí)時(shí)實(shí)現(xiàn)監(jiān)控一個(gè)文件夾功能，將監(jiān)控到的 Excel（筆者目前用于解析excel文件）解析寫到 mysql 中，起功能和 sparkStreaming 中的?textFileStream 功能，個(gè)人感覺 python 代碼更好看。畢竟 java 代碼看起來比較繁瑣，scala 代碼簡潔，可是它也是借鑒 python 發(fā)展而來啊。

python 實(shí)現(xiàn)看門狗功能代碼：

            
              #!/usr/bin/python
#-*- coding:UTF-8 -*-

import time
from watchdog.events import *
from watchdog.observers import Observer

class FileEventHandler(FileSystemEventHandler):
    def __init__(self):
        FileSystemEventHandler.__init__(self)

    def on_moved(self, event):
        if event.is_directory:
            print("directory moved from {0} to {1}".format(event.src_path, event.dest_path))
        else:
            print("file moved from {0} to {1}".format(event.src_path, event.dest_path))

    def on_created(self, event):
        if event.is_directory:
            print("directory created:{0}".format(event.src_path))
        else:
            print("file created:{0}".format(event.src_path))

    def on_deleted(self, event):
        if event.is_directory:
            print("directory deleted:{0}".format(event.src_path))
        else:
            print("file deleted:{0}".format(event.src_path))

    def on_modified(self, event):
        if event.is_directory:
            print("directory modified:{0}".format(event.src_path))
        else:
            print("file modified:{0}".format(event.src_path))

if __name__ == "__main__":
    observer = Observer()
    event_handler = FileEventHandler()
    observer.schedule(event_handler, "E:/Jerry", True)
    observer.start()
    try:
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        observer.stop()
    observer.join()
            
          

這里是一個(gè)簡化版的監(jiān)控文件夾代碼，一般會(huì)改動(dòng) on_modified 方法里的代碼（根據(jù)需求來改動(dòng)）。

?

?

?