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

feat: フォーマット、コメント追加

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2025-06-05 13:43:40 +09:00
parent 80b4562a32
commit bb64d5d732
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
ecs/jskult-batch/src/batch/update_business_day.py
View File

@ -1,18 +1,19 @@
import json import json
import boto3
from datetime import datetime from datetime import datetime
from src.batch.jskult_batch_entrypoint import JskultBatchEntrypoint
from src.aws.s3 import (ConfigBucket, import boto3
JskTransferListBucket)
from src.aws.s3 import ConfigBucket, JskTransferListBucket
from src.batch.common.calendar_file import CalendarFile from src.batch.common.calendar_file import CalendarFile
from src.batch.environment.update_business_day_environment import \ from src.batch.environment.update_business_day_environment import \
UpdateBusinessDayEnvironment UpdateBusinessDayEnvironment
from src.manager.jskult_batch_run_manager import JskultBatchRunManager from src.batch.jskult_batch_entrypoint import JskultBatchEntrypoint
from src.manager.jskult_batch_status_manager import JskultBatchStatusManager
from src.manager.jskult_hdke_tbl_manager import JskultHdkeTblManager
from src.error.exceptions import (EnvironmentVariableNotSetException, from src.error.exceptions import (EnvironmentVariableNotSetException,
MaxRunCountReachedException) MaxRunCountReachedException)
from src.logging.get_logger import get_logger from src.logging.get_logger import get_logger
from src.manager.jskult_batch_run_manager import JskultBatchRunManager
from src.manager.jskult_batch_status_manager import JskultBatchStatusManager
from src.manager.jskult_hdke_tbl_manager import JskultHdkeTblManager
from src.system_var import constants from src.system_var import constants
logger = get_logger('日付テーブル更新') logger = get_logger('日付テーブル更新')
@ -135,15 +136,16 @@ class UpdateBusinessDay(JskultBatchEntrypoint):
constants.PROCESS_STATUS_ERROR) constants.PROCESS_STATUS_ERROR)
return return
with open(jsk_expected_data_path) as f: with open(jsk_expected_data_path) as f:
jsk_expected_data_list = json.load(f) jsk_expected_data_list = json.load(f)
jsk_transfer_expected_data_list = jsk_expected_data_list['jsk_transfer_list'] jsk_transfer_expected_data_list = jsk_expected_data_list['jsk_transfer_list']
if len(jsk_transfer_data_list) != 0: if len(jsk_transfer_data_list) != 0:
# 不足ファイルがあった場合ログ出力
self._check_missing_received_files( self._check_missing_received_files(
jsk_transfer_expected_data_list, jsk_transfer_data_list) jsk_transfer_expected_data_list, jsk_transfer_data_list)
# 受領予定にないファイルがあった場合ログ出力
self._check_extra_received_files( self._check_extra_received_files(
jsk_transfer_expected_data_list, jsk_transfer_data_list) jsk_transfer_expected_data_list, jsk_transfer_data_list)