Changeset 40892 for branches/ipp-132_automate_jira_conf_backups/backups/backup_atlassian_applications.py

Timestamp:

Sep 20, 2019, 4:01:54 PM (7 years ago)

Author:

fairlamb

Message:

Added the mysql dump part and refactored some testing

File:

• branches/ipp-132_automate_jira_conf_backups/backups/backup_atlassian_applications.py (modified) (4 diffs)

branches/ipp-132_automate_jira_conf_backups/backups/backup_atlassian_applications.py

@@ -6 +6 @@
 import os.path as path
 import shutil
+import subprocess
 import sys
 
@@ -29 +30 @@
 
 DEFAULT_VERBOSITY = False
+
+
+class SubprocessError(Exception):
+    """Errors in Popen stderr subprocess"""
 
 
@@ -198 +203 @@
             # If any failed: delete latest, move tmp back
             _move_dir_contents_to_dir(tmp_paths, latest_paths)
+            return 5
 
         # TODO:clean-up old files (to save space)
@@ -290 +296 @@
         return 0
 
-    def make_mysql_dump(self):
+    def make_mysql_dump(self, dump_password, dump_name=None):
         # do this as the dumper user
 
+        latest_paths = self.target_paths("latest")
+        if not self.target_backup_paths_ok():
+            return 1
+
         # make sure target file does not exist (or it will fail)
-
-        # verify mysql checksum?
+        if dump_name is None:
+            date = datetime.date.today().strftime("%Y_%m_%d")
+            dump_filepath = path.join(latest_paths[0], '{0}_mysql_dump.sql'.format(date))
+        else:
+            dump_filepath = path.join(latest_paths[0], dump_name)
+        if path.exists(dump_filepath):
+            print("Warning: SQL dump already exists: ", dump_filepath)
+            return 2
+
+        # Setup the commands:
+        mysqldump_args = [ 'mysqldump', '-u', 'dumper', '-p{0}'.format(dump_password)
+                         , '--databases', 'jiradb', 'confluencedb'
+                         ]
+        with open(dump_filepath, "w+") as df:
+            mysqldump_process = subprocess.Popen(mysqldump_args, stdout=df, stderr=subprocess.PIPE)
+            dump_result = mysqldump_process.communicate()
+
+        # Get the piped std err. See it contains the word error
+        stdo, stde = dump_result
+        if stde is not None:
+            decoded_stderr = stde.decode()
+            if decoded_stderr.casefold().find('error'.casefold()) > -1:
+                raise SubprocessError()
 
         # move the dump file to the correct locations
+        if not path.exists(dump_filepath):
+            return 2
+        cp_1 = sub_utils.cp_wrapper([dump_filepath, latest_paths[1]])
+        cp_2 = sub_utils.cp_wrapper([dump_filepath, latest_paths[2]])
+        if cp_1 != 0:
+            return cp_1
+        if cp_2 != 0:
+            return cp_2
         return 0