仮完成２

ecs/jskult-dbdump/.env.example

@@ -5,7 +5,6 @@ DB_PASSWORD=************
 DB_SCHEMA=src05
 
 JSKULT_BACKUP_BUCKET=mbj-newdwh2021-staging-backup-jskult
-JSKULT_CONFIG_BUCKET=mbj-newdwh2021-staging-config
 
 DUMP_BACKUP_FOLDER=dump
 

ecs/jskult-dbdump/src/jobctrl_dbdump.py

@@ -57,6 +57,23 @@ def exec():
         with open(my_cnf_path, 'w') as f:
             f.write(textwrap.dedent(my_cnf_file_content)[1:-1])
 
+        #***************************************************************
+        # # MySQLコマンドを実行する
+        # command = ['mysqldump', f'--defaults-file={my_cnf_path}', '-P', f"'{environment.DB_PORT}'", environment.DB_SCHEMA]
+        # mysqldump_process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+        # # gzipコマンドを実行して圧縮する
+        # gzip_process = subprocess.Popen(['gzip'], stdin=mysqldump_process.stdout, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
+        # # aws s3 cpコマンドを実行してアップロードする
+        # s3_cp_process = subprocess.Popen(['aws', 's3', 'cp', '-', s3_file_name], stdin=gzip_process.stdout ,stderr=subprocess.PIPE)
+        # # 出力を取得する
+        # mysqldump_process.stdout.close()
+        # _, error = s3_cp_process.communicate()
+
+        # if s3_cp_process.returncode != 0:
+        #     print("Error: ", error.decode("utf-8"))
+        #     raise Exception('Error')
+        #***************************************************************
+
         dt_now = datetime.datetime.now()
         converted_value = dt_now.strftime('%Y%m%d%H%M%S')
         file_name = f'backup_rds_src05_{converted_value}.gz'
@@ -70,7 +87,6 @@ def exec():
         '--port={db_port}'.format(db_port=environment.DB_PORT),
         '{db_name}'.format(db_name=environment.DB_SCHEMA)
         ]
-
         # mysqldumpコマンドを実行してデータを標準出力に出力
         mysqldump_output = subprocess.check_output(mysqldump_cmd)
 

ecs/jskult-dbdump/src/system_var/environment.py

@@ -9,7 +9,6 @@ DB_SCHEMA = os.environ['DB_SCHEMA']
 
 # AWS
 JSKULT_BACKUP_BUCKET = os.environ['JSKULT_BACKUP_BUCKET']
-JSKULT_CONFIG_BUCKET = os.environ['JSKULT_CONFIG_BUCKET']
 
 # 初期値がある環境変数
 LOG_LEVEL = os.environ.get('LOG_LEVEL', 'INFO')