planetstack/ec2_observer/backend.py

   1 import threading
   2 import time
   3 from ec2_observer.event_loop import PlanetStackObserver
   4 from ec2_observer.event_manager import EventListener
   5 from util.logger import Logger, logging
   6
   7 logger = Logger(level=logging.INFO)
   8
   9 class Backend:
  10
  11     def run(self):
  12         # start the openstack observer
  13         observer = PlanetStackObserver()
  14         observer_thread = threading.Thread(target=observer.run)
  15         observer_thread.start()
  16
  17         # start event listene
  18         event_manager = EventListener(wake_up=observer.wake_up)
  19         event_manager_thread = threading.Thread(target=event_manager.run)
  20         event_manager_thread.start()
  21         logger.log_exc("Exception in child thread")
  22