diff --git a/concurrency/FileUploadThread.py b/concurrency/FileUploadThread.py index 069f921..96050e0 100644 --- a/concurrency/FileUploadThread.py +++ b/concurrency/FileUploadThread.py @@ -27,6 +27,18 @@ class FileUpload(Thread): self._storage_source = self._context['service']['storage_source'] self._algStatus = False # 默认关闭 self._algSwitch = self._context['service']['algSwitch'] + + + # for algswitch flag: + default_enabled = str(self._msg.get("defaultEnabled","True")).lower() == "true" + + if default_enabled: + self._algSwitch= True + else: + self._algSwitch= False + + + #如果任务是在线、离线处理,则用此类 class ImageFileUpload(FileUpload): __slots__ = () diff --git a/concurrency/PushVideoStreamProcess.py b/concurrency/PushVideoStreamProcess.py index 2004da7..efdd2b2 100644 --- a/concurrency/PushVideoStreamProcess.py +++ b/concurrency/PushVideoStreamProcess.py @@ -36,7 +36,17 @@ class PushStreamProcess(Process): # 传参 self._msg, self._push_queue, self._image_queue, self._push_ex_queue, self._hb_queue, self._context = args self._algStatus = False # 默认关闭 - self._algSwitch = self._context['service']['algSwitch'] + self._algSwitch = self._context['service']['algSwitch'] + + + # for algswitch flag: + default_enabled = str(self._msg.get("defaultEnabled","True")).lower() == "true" + + if default_enabled: + self._algSwitch= True + else: + self._algSwitch= False + def build_logo_url(self): logo = None diff --git a/service/Dispatcher.py b/service/Dispatcher.py index 0641c05..25c3c7f 100644 --- a/service/Dispatcher.py +++ b/service/Dispatcher.py @@ -244,6 +244,17 @@ class DispatcherService: # 开启实时进程 def startOnlineProcess(self, msg, analysisType): + + + # for algswitch flag: + default_enabled = str(msg.get("defaultEnabled","True")).lower() == "true" + + if default_enabled: + self.__context['service']['algSwitch'] = True + else: + self.__context['service']['algSwitch'] = False + + if self.__listeningProcesses.get(msg["request_id"]): logger.warning("实时重复任务,请稍后再试!requestId:{}", msg["request_id"]) return