AI提取上线

BaseDataMaintenance/common/activateMQUtils.py

@@ -39,7 +39,7 @@ class MyListener(object):
         # self.conn.nack(message_id,"")
 
 def ackMsg(conn,message_id,subscription=""):
-    log("ack message:%s"%(message_id))
+    log("ack message:%s conn:%s"%(message_id,str(conn)))
     try:
         conn.ack(message_id,subscription)
     except Exception as e:

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -1355,7 +1355,6 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
         _extract_json = None
         if document_extract2_extract_json in item:
             _extract_json = item.get(document_extract2_extract_json)
-            item.pop(document_extract2_extract_json)
 
 
         try:
@@ -1400,8 +1399,6 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
 
             dhtml.setValue(document_tmp_dochtmlcon,_dochtmlcon,True)
 
-            extract_times = item.get("extract_times",0)+1
-            item["extract_times"] = extract_times
 
 
             _extract_ai = {}