| | |
| | | from .ControllThread import ControllThread |
| | | from .MicroWaveUDPThread import MicroWaveUDPThread |
| | | from . import MessageThreads as ths |
| | | from .CameraDevice import cameraController |
| | | from .devices import cameraController |
| | | |
| | | # add python path of src to sys.path |
| | | src_path = os.path.join(__file__, *(['..'] * 2)) |
| | |
| | | "ply_data":self.ply_data_queue |
| | | } |
| | | |
| | | # device |
| | | self.cc = None # camera controller |
| | | self.mc = None # microwave controller |
| | | self.dc = None # dust cleaner controller |
| | | self.rc = None # rotation device controler |
| | | |
| | | self.controller_dict = { |
| | | "camera": self.cc, |
| | | "microwave":self.mc, |
| | | "dustcleaner":self.dc, |
| | | "rotation": self.rc |
| | | } |
| | | |
| | | |
| | | def _connect_to_MQ(self): |
| | | credentials = pika.PlainCredentials(self.MQuser, self.MQpassword) |
| | |
| | | # connecting to camera via opencv |
| | | cc.open_cameras() |
| | | # capture the data, and wrap it to data queue |
| | | # cc._start_captureThread() |
| | | cc._start_captureThread() |
| | | |
| | | |
| | | def connecting_microwave(self): |
| | |
| | | self._stop_alarm_state_up_msg_sender_thread() |
| | | self.stop |
| | | print("main thread end.") |
| | | return 0 |
| | | |
| | | |
| | | |