nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #245 feature-NEWDWH2021-1171 into develop

Browse Source
This commit is contained in:
下田雅人 2023-08-03 14:05:19 +09:00
commit 1b4b3a9a97
1 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
ecs/jskult-dbdump/src/jobctrl_dbdump.py
View File

@ -23,8 +23,7 @@ def exec():
# 日次バッチ処置中フラグ、dump処理状態区分を取得 # 日次バッチ処置中フラグ、dump処理状態区分を取得
batch_processing_flag, dump_status_kbn = get_batch_statuses() batch_processing_flag, dump_status_kbn = get_batch_statuses()
except BatchOperationException as e: except BatchOperationException as e:
logger.exception(f'日付テーブル取得エラー（異常終了）:{e}') raise BatchOperationException(f'日付テーブル取得エラー（異常終了）:{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
# 日次バッチ処理中の場合、処理は行わない # 日次バッチ処理中の場合、処理は行わない
if batch_processing_flag == constants.BATCH_ACTF_BATCH_IN_PROCESSING: if batch_processing_flag == constants.BATCH_ACTF_BATCH_IN_PROCESSING:
@ -45,8 +44,7 @@ def exec():
try: try:
update_dump_status_kbn_in_processing() update_dump_status_kbn_in_processing()
except BatchOperationException as e: except BatchOperationException as e:
logger.exception(f'dump処理状態区分更新(未処理→処理中) エラー（異常終了）:{e}') raise BatchOperationException(f'dump処理状態区分更新(未処理→処理中) エラー（異常終了）:{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
# MySQL接続情報を作成する # MySQL接続情報を作成する
my_cnf_file_content = f""" my_cnf_file_content = f"""
@ -93,25 +91,21 @@ def exec():
# パイプラインを実行し、エラーハンドリング # パイプラインを実行し、エラーハンドリング
_, error = mysqldump_process.communicate() _, error = mysqldump_process.communicate()
if mysqldump_process.returncode != 0: if mysqldump_process.returncode != 0:
logger.error(f'`mysqldump`実行時にエラーが発生しました。{"" if error is None else error.decode("utf-8")}') raise BatchOperationException(f'`mysqldump`実行時にエラーが発生しました。{"" if error is None else error.decode("utf-8")}')
return constants.BATCH_EXIT_CODE_SUCCESS
_, error = gzip_process.communicate() _, error = gzip_process.communicate()
if gzip_process.returncode != 0: if gzip_process.returncode != 0:
logger.error(f'`gzip`実行時にエラーが発生しました。{"" if error is None else error.decode("utf-8")}') raise BatchOperationException(f'`gzip`実行時にエラーが発生しました。{"" if error is None else error.decode("utf-8")}')
return constants.BATCH_EXIT_CODE_SUCCESS
_, error = s3_cp_process.communicate() _, error = s3_cp_process.communicate()
if s3_cp_process.returncode != 0: if s3_cp_process.returncode != 0:
logger.error(f'`aws s3 cp`実行時にエラーが発生しました。{"" if error is None else error.decode("utf-8")}') raise BatchOperationException(f'`aws s3 cp`実行時にエラーが発生しました。{"" if error is None else error.decode("utf-8")}')
return constants.BATCH_EXIT_CODE_SUCCESS
# dump処理状態区分を正常終了に更新 # dump処理状態区分を正常終了に更新
try: try:
update_dump_status_kbn_complete() update_dump_status_kbn_complete()
except BatchOperationException as e: except BatchOperationException as e:
logger.exception(f'dump処理状態区分更新(処理中→正常終了) エラー（異常終了）:{e}') raise BatchOperationException(f'dump処理状態区分更新(処理中→正常終了) エラー（異常終了）:{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
logger.info('日次バッチ処理前DBダンプ取得：終了（正常終了）') logger.info('日次バッチ処理前DBダンプ取得：終了（正常終了）')
logger.info(f'出力ファイルパス: {s3_file_path}') logger.info(f'出力ファイルパス: {s3_file_path}')