Merge pull request #185 from jumpserver/dev

[Update] 修改命令上传

coco/app.py

@@ -9,7 +9,6 @@ import threading
 import json
 import signal
 import copy
-from collections import defaultdict
 
 from .conf import config
 from .sshd import SSHServer

coco/recorder.py

@@ -170,9 +170,10 @@ class CommandRecorder(object):
                 if not data_set:
                     continue
                 logger.debug("Send {} commands to server".format(len(data_set)))
-                ok = self.storage.bulk_save(data_set)
-                if not ok:
-                    self.queue.mput(data_set)
+                for i in range(5):
+                    ok = self.storage.bulk_save(data_set)
+                    if ok:
+                        break
 
         thread = threading.Thread(target=func)
         thread.daemon = True