watch_and_process.py

# import time module, Observer, FileSystemEventHandler
import time # Import Time
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
import os

class OnMyWatch:
	# Set the directory on watch
	watchDirectory = "/filessource"
	
	def __init__(self):
		self.observer = Observer()

	def run(self):
		event_handler = Handler()
		self.observer.schedule(event_handler, self.watchDirectory, recursive = True)
		self.observer.start()
		try:
			while True:
				time.sleep(5)
		except:
			self.observer.stop()
			print("Observer Stopped")

		self.observer.join()

class Handler(FileSystemEventHandler):

	@staticmethod
	def on_any_event(event):
		if event.is_directory:
			return None

		elif event.event_type == 'created' or event.event_type == 'modified':
			print("Watchdog received created event - % s." % event.src_path)
			os.system('python decode-config.py -s '+event.src_path+' -o /filedestination/'+os.path.basename(event.src_path).split('/')[-1]+'.json -t json --json-indent 2')
if __name__ == '__main__':
	watch = OnMyWatch()
	watch.run()