| | |
|---|
| | | channel.queue_declare(queue=device_id + "_callback") |
|---|
| | | return channel |
|---|
| | | |
|---|
| | | def get_device(self, device_id: str): |
|---|
| | | def get_device(self, device_id: str, save_folder: str): |
|---|
| | | device = self._devices.get(device_id, None) |
|---|
| | | if device is None: |
|---|
| | | start = datetime.datetime.now() |
|---|
| | | if not os.path.exists('./Images'): |
|---|
| | | os.mkdir('./Images') |
|---|
| | | path = f"./Images/{device_id}-{start.strftime('%Y-%m-%d-%H-%M-%S')}" |
|---|
| | | if not os.path.exists(save_folder): |
|---|
| | | os.mkdir(save_folder) |
|---|
| | | path = os.path.join(save_folder,f"{device_id}-{start.strftime('%Y-%m-%d-%H-%M-%S')}") |
|---|
| | | if not os.path.exists(path): |
|---|
| | | os.mkdir(path) |
|---|
| | | device = dict( |
|---|
