chage for admin in separate folder

Author: biswazr

mongodb_consistent_backup/Archive/Tar/TarThread.py

@@ -30,18 +30,22 @@ def run(self):
                 try:
                     backup_base_dir  = os.path.dirname(self.backup_dir)
                     backup_base_name = os.path.basename(self.backup_dir)
+                    admin_backup_file = "_".join("admin",self.output_file)
 
                     log_msg   = "Archiving directory: %s" % self.backup_dir
-                    cmd_flags = ["-C", backup_base_dir, "-c", "-f", self.output_file, "--remove-files"]
+                    cmd_flags = ["-C", backup_base_dir, "-c", "-f", self.output_file, "--exclude", "admin" ,"--remove-files"]
+                    admin_cmd_flags = ["-C", backup_base_dir, "-c", "-f", admin_backup_file, "admin", "--remove-files"]
+                    
 
                     if self.do_gzip():
                         log_msg = "Archiving and compressing directory: %s" % self.backup_dir
                         cmd_flags.append("-z")
+                        admin_cmd_flags.append("-z")
 
                     cmd_flags.append(backup_base_name)
                     logging.info(log_msg)
                     self.running  = True
-                    self._command = LocalCommand(self.binary, cmd_flags, self.verbose)
+                    self._command = LocalCommand(self.binary, cmd_flags, admin_cmd_flags, self.verbose)
                     self.exit_code = self._command.run()
                 except Exception, e:
                     return self.result(False, "Failed archiving file: %s!" % self.output_file, e)

mongodb_consistent_backup/Backup/Mongodump/MongodumpThread.py

@@ -173,7 +173,7 @@ def mongodump_cmd(self):
             logging.info("MongoDump Version higher that 4.2.0 found extending mongodump with snppy compressor flag")
             ## https://www.mongodb.com/docs/drivers/node/v4.4/fundamentals/connection/network-compression/
             mongodump_flags.extend([
-                "--compressors=%s" % "snappy,zlib,zstd"
+                "--compressors=%s" % "zstd,snappy,zlib"
             ])
 
         # --numParallelCollections

mongodb_consistent_backup/Common/LocalCommand.py

@@ -7,11 +7,14 @@
 
 
 class LocalCommand:
-    def __init__(self, command, command_flags=None, verbose=False):
+    def __init__(self, command, command_flags=None, admin_cmd_flags=None, verbose=False):
         if command_flags is None:
             command_flags = []
+        if admin_command_flags is None:
+            admin_command_flags = []
         self.command       = command
         self.command_flags = command_flags
+        self.admin_command_flags = command_flags
         self.verbose       = verbose
 
         self.output   = []
@@ -21,6 +24,10 @@ def __init__(self, command, command_flags=None, verbose=False):
         if len(self.command_flags):
             self.command_line.extend(self.command_flags)
 
+        self.admin_command_line = [self.command]
+        if len(self.admin_command_flags):
+            self.admin_command_line.extend(self.command_flags)
+
     def parse_output(self):
         if self._process:
             try:
@@ -36,7 +43,7 @@ def parse_output(self):
 
     def run(self):
         try:
-            self._process = Popen(self.command_line, stdout=PIPE, stderr=PIPE)
+            self._process = Popen(self.command_line+" && "+ self.admin_command_line, stdout=PIPE, stderr=PIPE)
             while self._process.poll() is None:
                 self.parse_output()
                 sleep(0.1)