前後処理prepost_exec追加

This commit is contained in:
nik.n 2024-02-21 17:07:24 +09:00
parent 0459668032
commit 37b9bc6112
2 changed files with 24 additions and 1 deletions

View File

@ -2,7 +2,7 @@
## 概要
【共通】DBダンプ取得処理
当処理は特定の機能で利用するものではなく、共通処理として要件に応じて実行することを想定している
## 環境情報

View File

@ -15,6 +15,10 @@ def exec():
try:
logger.info('DBダンプ取得開始')
# 事前処理(共通処理としては空振りする)
_pre_exec()
# メイン処理
# MySQL接続情報を作成する
my_cnf_file_content = f"""
[client]
@ -74,6 +78,9 @@ def exec():
if s3_cp_process.returncode != 0:
raise Exception(f'`aws s3 cp`実行時にエラーが発生しました。{"" if error is None else error.decode("utf-8")}')
# 事後処理(共通処理としては空振りする)
_post_exec()
logger.info('DBダンプ取得終了正常終了')
logger.info(f'出力ファイルパス: {s3_file_path}')
return constants.BATCH_EXIT_CODE_SUCCESS
@ -81,3 +88,19 @@ def exec():
except Exception as e:
logger.exception(f'DBダンプ取得中に想定外のエラーが発生しました :{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
def _pre_exec():
"""
ダンプ復元 事前処理
共通機能としては事前処理を実装しない
事前処理が必要なダンプ復元処理を実装する場合当ロジックをコピーする
"""
pass
def _post_exec():
"""
ダンプ復元 事後処理
共通機能としては事後処理を実装しない
事後処理が必要なダンプ復元処理を実装する場合当ロジックをコピーする
"""
pass