附件数据处理1/10的概率不做处理重新排队列以防止单一数据堵塞队列

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -160,6 +160,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
             _dochtmlcon = item.get(document_tmp_dochtmlcon,"")
 
             if random.random()<0.1:
+                log("jump by random")
                 if send_msg_toacmq(self.pool_mq,json.dumps(item,cls=MyEncoder,ensure_ascii=False),self.mq_attachment):
                     return