要素提取补充AI提取

BaseDataMaintenance/AIUtils/DoubaoUtils.py

@@ -49,7 +49,7 @@ def chat_doubao(msg,stream=False,retry_time=3,model_name=model_name):
             return result
         except Exception as e:
             traceback.print_exc()
-            time.sleep(10)
+            time.sleep(30)
 
 def chat_doubao_messages(messages,stream=False,retry_time=3,model_name = "ep-20241226161807-95wp8"):
 

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -854,7 +854,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
 
 
 
-    def start_extract_AI_listener(self,_count=2):
+    def start_extract_AI_listener(self,_count=4):
 
         self.list_extract_ai_comsumer = []