मॉनिटरिंग फाइल सिस्टम बदल जाता है

FS में परिवर्तन की निगरानी के कार्य को हल करने के लिए एक समाप्त बाइक की खोज में linux + freebsd समर्थन के साथ, मैं एक अच्छा अजगर वॉचडॉग lib ( github , package.python.org ) पर आया था। जो दिलचस्प ओएस के अलावा, यह मैकओएस (अपनी खुद की बारीकियों) और विंडोज का भी समर्थन करता है।
मैं उन लोगों से पूछता हूं जो इस सवाल में रुचि रखते हैं और जो लेखक के भारतीय मूल से डरेंगे नहीं ।

स्थापना

आप तैयार संस्करण PIP से ले सकते हैं:
$ पाइप स्थापित प्रहरी
पीआईपी ही एक अजगर-पाइप पैकेज, पोर्ट डेवेल / पी-पाइप, आदि के रूप में स्थापित है।
या setup.py के माध्यम से स्रोत से निर्माण।

मूल मैनुअल में सब कुछ पर्याप्त विवरण में वर्णित है। सच है, संस्करण 0.5.4 का विवरण है, और अब 0.6.0 प्रासंगिक है। हालाँकि, पूरा अंतर कॉपीराइट्स को संपादित करने और 4 रिक्त स्थान के इंडेंट को 2 के इंडेंट के साथ बदलने का है। "Google कोड शैली"

सामान्य तौर पर, पायथन के संस्करणों और लक्ष्य प्लेटफॉर्म पर विधानसभा की काफी कुछ विशेषताएं हैं। वे सभी ऊपर दिए गए लिंक द्वारा वर्णित हैं, लेकिन यदि आवश्यक हो, तो मैं रूसी में संक्षेप में लेख में जोड़ दूंगा।

इसके अलावा, आप एक असंगत ओएस पर मॉड्यूल का निर्माण कर सकते हैं, लेकिन फिर फॉलबैक कार्यान्वयन खेल में आ जाएगा, जिससे बाद की तुलना के साथ एफएस संरचना के "कास्ट" बनेंगे। शायद यह है कि किसी ने ऐसी समस्या को हल करते समय क्या किया :)

मैंने खुद ubuntu 11.4 और freebsd-8.2 RELEASE के तहत निर्माण करने की कोशिश की, विधानसभा और संचालन के साथ कोई समस्या नहीं थी।

मूल उदाहरण

मान लीजिए कि हम फ़ाइलों और निर्देशिकाओं के निर्माण, विलोपन और नामकरण से संबंधित एक निश्चित पथ / पथ / / smth में परिवर्तन में रुचि रखते हैं।

हम कनेक्ट:

from watchdog.observers import Observer from watchdog.events import FileSystemEventHandler 

ऑब्ज़र्वर वर्ग का चयन आपके OS की क्षमताओं के आधार पर /observers/__init__.py में किया जाता है, इसलिए स्वयं के लिए निर्णय लेने की आवश्यकता नहीं है कि क्या चुनना है।
FileSystemEventHandler वर्ग परिवर्तन इवेंट हैंडलर का आधार वर्ग है। वह बहुत कुछ नहीं जानता, लेकिन हम उसके वंश को सिखाएंगे:

 class Handler(FileSystemEventHandler): def on_created(self, event): print event def on_deleted(self, event): print event def on_moved(self, event): print event 

FileSystemEventHandler.dispatch में विधियों की एक पूरी सूची देखी जा सकती है: on_modified, on_moved, on_created, on_deleted।

हम इसे शुरू करते हैं:

 observer = Observer() observer.schedule(Handler(), path='/path/to/smth', recursive=True) observer.start() 

ऑब्जर्वर थ्रेडिंग का अपेक्षाकृत दूर का वंशज है। शुरू में () कॉल करने के बाद क्रमशः, हमें एक बैकग्राउंड थ्रेड मिलता है जो बदलावों पर नज़र रखता है। इसलिए यदि स्क्रिप्ट तुरंत समाप्त हो जाती है, तो हमें कुछ भी समझदार नहीं मिलेगा। अपेक्षा का कार्यान्वयन मुख्य रूप से एक वास्तविक परियोजना में मॉड्यूल के आवेदन पर निर्भर करता है, अब आप बस एक बैसाखी बना सकते हैं:

 try: while True: time.sleep(0.1) except KeyboardInterrupt: observer.stop() observer.join() 

हम Ctrl + C (SIGINT) आने तक FS परिवर्तनों की घटनाओं की प्रतीक्षा कर रहे हैं, जिसके बाद हम अपने धागे को समाप्त होने के लिए कहते हैं और इसे पूरा करने के लिए प्रतीक्षा करते हैं।

स्क्रिप्ट चलाएँ, हमारे रास्ते पर जाएँ और:

 # mkdir foo # touch bar # mv bar baz # cd foo/ # mkdir foz # mv ../baz ./quz # cp ./quz ../hw # cd .. # rm -r ./foo # rm -f ./* 

हमारे पास स्क्रिप्ट के आउटपुट पर:

 <DirCreatedEvent: src_path=/path/to/smth/foo> <FileCreatedEvent: src_path=/path/to/smth/bar> <FileMovedEvent: src_path=/path/to/smth/bar, dest_path=/path/to/smth/baz> <DirCreatedEvent: src_path=/path/to/smth/foo/foz> <FileMovedEvent: src_path=/path/to/smth/baz, dest_path=/path/to/smth/foo/quz> <FileCreatedEvent: src_path=/path/to/smth/hw> <FileDeletedEvent: src_path=/path/to/smth/foo/quz> <DirDeletedEvent: src_path=/path/to/smth/foo/foz> <DirDeletedEvent: src_path=/path/to/smth/foo> <FileDeletedEvent: src_path=/path/to/smth/hw> 

ईवेंट फ़ील्ड में हमारे हैंडलर क्लास के तरीके, वॉचडॉग / ईवेंटसोम्स में सूचीबद्ध फ़ाइलसिस्टमइवेंट के वंशज हैं।
सभी के पास src_path, is_directory, event_type ("बनाया गया", "हटाए गए", आदि) गुण हैं। स्थानांतरित घटना के लिए, dest_path गुण जोड़ा जाता है।

ठीक है, अगर आप कुछ और नहीं चाहते हैं ... क्या कुछ और है?

शुरुआत के लिए, हमारे पास अभी भी FileSystemEventHandler के वंशज हैं :

• PatternMatchingEventHandler
• RegexMatchingEventHandler
• LoggingEventHandler

PatternMatchingEventHandler का उपयोग केवल उन FS नोड्स पर घटनाओं को प्राप्त करने के लिए किया जा सकता है जिनके नाम नियमों के साथ मुखौटा से मेल खाते हैं:

• * कोई भी पात्र
• ? कोई एकल चरित्र
• [seq] निर्दिष्ट का कोई एकल वर्ण
• [! seq] कोई भी एकल वर्ण निर्दिष्ट से नहीं है

बनाते समय नियम निर्धारित होते हैं:

 class Handler(PatternMatchingEventHandler): pass event_handler = Handler( patterns = ['*.py*'], ignore_patterns = ['cache/*'], ignore_directories = True, case_sensitive = False ) observer = Observer() observer.schedule(event_handler, path='/home/LOGS/', recursive=True) 

RegexMatchingEventHandler वही करता है, लेकिन निर्माणकर्ता में स्पष्ट regexp अभिव्यक्तियों के साथ:

 class Handler(RegexMatchingEventHandler): pass event_handler = Handler( regexes = ['\.py.?'], ignore_regexes = ['cache/.*'], ignore_directories = True, case_sensitive = False ) 

नतीजतन, PatternMatchingEventHandler आंतरिक रूप से नियमित पैटर्न में अनुवाद करता है, इसलिए इस तरह के ओवरहेड की उपस्थिति के कारण इसे अधिक धीरे-धीरे काम करना चाहिए।

अंत में, LoggingEventHandler logging.info () के माध्यम से सब कुछ लॉग करता है।

- बस इतना ही। शायद कोई काम आएगा।

पुनश्च
जब कोई निर्देशिका जिसमें (और उसके बच्चों के) में फ़ोल्डर / फाइलें होती हैं, जिसमें कोई एससीआई नाम नहीं होता है, एक अपवाद अपवाद। UnicodeEncodeError वॉचडॉग की गहराई में घटित होगा। Linux (inotify) पर, यह watchdog.observers.inotify.Inotify._add_watch में होता है।
कारण एएससीआई एन्कोडिंग में सामग्री को पढ़ रहा है।
स्थिति को ठीक करने के लिए, आप विधि को पैच कर सकते हैं:

 from watchdog.observers.inotify import Inotify _save = Inotify._add_watch Inotify._add_watch = lambda self, path, mask: _save(self, path.encode('utf-8'), mask) 

यहाँ एन्कोड करने से पहले और बाद में मूल स्ट्रिंग का उदाहरण दिया गया है, और इसकी रीप्र ()

 /home/atercattus/.wine/drive_c/users/Public/  u'/home/atercattus/.wine/drive_c/users/Public/\u0420\u0430\u0431\u043e\u0447\u0438\u0439 \u0441\u0442\u043e\u043b' '/home/atercattus/.wine/drive_c/users/Public/\xd0\xa0\xd0\xb0\xd0\xb1\xd0\xbe\xd1\x87\xd0\xb8\xd0\xb9 \xd1\x81\xd1\x82\xd0\xbe\xd0\xbb'