修复附件数据处理异常Failed to establish a new connection

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -77,7 +77,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
 
         self.queue_attachment_ocr = Queue()
         self.queue_attachment_not_ocr = Queue()
-        self.comsumer_count = 18
+        self.comsumer_count = 90
         self.comsumer_process_count = 5
         self.retry_comsumer_count = 10
         self.retry_times = 5
@@ -95,9 +95,12 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
 
         self.session = None
 
-        for _ in range(self.comsumer_process_count):
-            listener_p = Process(target=self.start_attachment_listener)
-            listener_p.start()
+        # for _ in range(self.comsumer_process_count):
+        #     listener_p = Process(target=self.start_attachment_listener)
+        #     listener_p.start()
+
+        listener_p = Process(target=self.start_attachment_listener)
+        listener_p.start()