mysql账号更新

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -774,13 +774,13 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
             self.list_extract_comsumer.append(listener_extract)
 
         while 1:
-            for i in range(len(self.list_extract_comsumer)):
-                if self.list_extract_comsumer[i].conn.is_connected():
+            for _i in range(len(self.list_extract_comsumer)):
+                if self.list_extract_comsumer[_i].conn.is_connected():
                     continue
                 else:
-                    listener = self.ExtractListener(getConnect_activateMQ(),self.comsumer_handle)
+                    listener = self.ExtractListener(getConnect_activateMQ(),self.comsumer_handle,_i)
                     createComsumer(listener,self.mq_extract)
-                    self.list_extract_comsumer[i] = listener
+                    self.list_extract_comsumer[_i] = listener
             time.sleep(5)
 
     def monitor_listener(self):

BaseDataMaintenance/maxcompute/documentMerge.py

@@ -2127,7 +2127,7 @@ def dumplicate_projects(list_projects,b_log=False):
     :return:
     '''
     appendKeyvalueCount(list_projects)
-    list_projects.sort(key=lambda x:x.get(project_page_time,""))
+    list_projects.sort(key=lambda x:str(x.get(project_page_time,"")))
     list_projects.sort(key=lambda x:x.get("keyvaluecount",0),reverse=True)
     cluster_projects = list_projects[:50]
     _count = 10