| | |
| | | # from .ControllThread import ControllThread |
| | | # from .MicroWaveUDPThread import MicroWaveUDPThread |
| | | from . import MessageThreads as ths |
| | | from .devices import cameraController, dustCleanerController |
| | | from .devices import cameraController, dustCleanerController,microwaveController |
| | | |
| | | # # add python path of src to sys.path |
| | | # src_path = os.path.join(__file__, *(['..'] * 2)) |
| | |
| | | self.MQpassword = MQpassword |
| | | self.parameters = None |
| | | # camera |
| | | self.IMAGE_WIDTH = 3840 |
| | | self.IMAGE_HEIGHT = 2880 |
| | | self.CAMERA_COUNT = 4 |
| | | self.IMAGE_WIDTH = IMAGE_WIDTH |
| | | self.IMAGE_HEIGHT = IMAGE_HEIGHT |
| | | self.CAMERA_COUNT = CAMERA_COUNT |
| | | # microwave |
| | | self.MICROWAVEhost = MICROWAVEhost |
| | | |
| | | # dust cleaner |
| | | self.com = "COM11" |
| | | self.bps = "115200" |
| | | self.timeout = 1 |
| | | |
| | | # threads |
| | | self.threads = [] |
| | | |
| | |
| | | def _connect_device(self): |
| | | # connect to cameras |
| | | self.cc = cameraController( |
| | | IMAGE_WIDTH=IMAGE_WIDTH, |
| | | IMAGE_HEIGHT=IMAGE_HEIGHT, |
| | | CAMERA_COUNT=CAMERA_COUNT, |
| | | IMAGE_WIDTH=self.IMAGE_WIDTH, |
| | | IMAGE_HEIGHT=self.IMAGE_HEIGHT, |
| | | CAMERA_COUNT=self.CAMERA_COUNT, |
| | | device_id=self.device_id, |
| | | logs_queue=self.LogsSender_queue, |
| | | images_queue=self.ImagesSender_queue, |
| | |
| | | init_routing_key="server" |
| | | |
| | | ) |
| | | # self.dc = dustCleanerController() |
| | | self.dc = dustCleanerController( |
| | | com = self.com, |
| | | bps = self.bps, |
| | | timeout=self.timeout, |
| | | logs_queue=self.LogsSender_queue, |
| | | device_id=self.device_id, |
| | | routing_key="server" |
| | | ) |
| | | |
| | | self.mc = microwaveController() |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | def run_rabbitmq(self): |
| | | self._connect_to_MQ() |