40 lines
1.7 KiB
Python
40 lines
1.7 KiB
Python
from src.aws.s3 import BackupBucket
|
|
from src.error.exceptions import FileUploadException
|
|
from src.system_var.constants import END_JP_NAME
|
|
from src.system_var.environments import PROCESS_RESULT_FILENAME
|
|
from src.util.execute_datetime import ExecuteDateTime
|
|
from src.util.logger import logger_instance as logger
|
|
|
|
|
|
def upload_result_data_process(process_result: dict, execute_datetime: ExecuteDateTime):
|
|
"""取得処理実施結果アップロード処理
|
|
|
|
Args:
|
|
process_result (dict): 取得処理実行結果辞書オブジェクト
|
|
execute_datetime (ExecuteDateTime): データ取得期間設定インスタンス
|
|
|
|
Raises:
|
|
FileUploadException: S3のファイルアップロード失敗
|
|
"""
|
|
|
|
# ① 取得処理実施結果アップロード処理のログを出力する
|
|
logger.info(
|
|
f'I-END-01 取得処理実施結果アップロード処理を開始します')
|
|
|
|
try:
|
|
# ② CRMバックアップ保管用バケットに、取得処理実施結果のJSONデータを保管する
|
|
backup_bucket = BackupBucket()
|
|
backup_bucket.put_result_json(
|
|
f'{execute_datetime.to_path()}/{PROCESS_RESULT_FILENAME}', process_result)
|
|
|
|
logger.debug(f'D-END-02 取得処理実施結果アップロード 正常終了')
|
|
|
|
except Exception as e:
|
|
raise FileUploadException(
|
|
'E-END-01', END_JP_NAME, f'取得処理実施結果のアップロードに失敗しました ファイル名：[{PROCESS_RESULT_FILENAME}] エラー内容：[{e}]')
|
|
|
|
# ③ 取得処理実施結果アップロード処理の終了ログを出力する
|
|
logger.info(f'I-END-03 取得処理実施結果アップロード処理を終了します')
|
|
|
|
return
|