diff --git a/ecs/jskult-batch-ultmarc-io/.env.example b/ecs/jskult-batch-ultmarc-io/.env.example index dfbf73e8..88b515c1 100644 --- a/ecs/jskult-batch-ultmarc-io/.env.example +++ b/ecs/jskult-batch-ultmarc-io/.env.example @@ -16,6 +16,7 @@ JSK_DATA_SEND_FOLDER=send JSKULT_BACKUP_BUCKET=**************** JSK_BACKUP_FOLDER=jsk/send DCF_DSF_SEND_FILE_NAME=ult_dcf_dsf.csv +IMPORT_FILE_KEY=**************** DB_CONNECTION_MAX_RETRY_ATTEMPT=4 DB_CONNECTION_RETRY_INTERVAL_INIT=5 diff --git a/ecs/jskult-batch-ultmarc-io/src/batch/ultmarc/import_ultmarc_process.py b/ecs/jskult-batch-ultmarc-io/src/batch/ultmarc/import_ultmarc_process.py index 1e92cf44..f0358b28 100644 --- a/ecs/jskult-batch-ultmarc-io/src/batch/ultmarc/import_ultmarc_process.py +++ b/ecs/jskult-batch-ultmarc-io/src/batch/ultmarc/import_ultmarc_process.py @@ -9,6 +9,7 @@ from src.batch.ultmarc.utmp_tables.ultmarc_table_mapper_factory import \ from src.db.database import Database from src.error.exceptions import BatchOperationException from src.logging.get_logger import get_logger +from src.system_var import environment logger = get_logger('アルトマーク取込') ultmarc_bucket = UltmarcBucket() @@ -22,9 +23,9 @@ def exec_import(): # datファイルをS3から取得する dat_file_list = ultmarc_bucket.list_dat_file() - # ファイルがない場合は処理せず、正常終了とする + # ファイルがない場合動いていないのは以上なので、エラーとする if len(dat_file_list) == 0: - logger.info('取込ファイルがないため、アルトマーク取込処理をスキップします') + raise BatchOperationException(f'取込ファイルが見つからないため、異常終了 ファイル一覧:{dat_file_list}') # ファイルが複数ある場合はエラーとする if len(dat_file_list) > 1: @@ -32,12 +33,14 @@ def exec_import(): # ファイルの件数は必ず1件になる dat_file_info = dat_file_list[0] + dat_file_name = dat_file_info['filename'] + if environment.IMPORT_FILE_KEY != dat_file_name: + raise BatchOperationException(f'取込対象のファイルが見つからないため、異常終了 ファイル名:{environment.IMPORT_FILE_KEY}') # 0Byteの場合、 if dat_file_info['size'] == 0: logger.info(f'0Byteファイルのため、処理をスキップします。ファイル名={dat_file_info["filename"]}') return - dat_file_name = dat_file_info['filename'] logger.info(f"{dat_file_name}を取り込みます") # datファイルをダウンロード local_file_path = ultmarc_bucket.download_dat_file(dat_file_name) diff --git a/ecs/jskult-batch-ultmarc-io/src/manager/jskult_hdke_tbl_manager.py b/ecs/jskult-batch-ultmarc-io/src/manager/jskult_hdke_tbl_manager.py index aecf3965..31984125 100644 --- a/ecs/jskult-batch-ultmarc-io/src/manager/jskult_hdke_tbl_manager.py +++ b/ecs/jskult-batch-ultmarc-io/src/manager/jskult_hdke_tbl_manager.py @@ -113,7 +113,7 @@ class JskultHdkeTblManager: finally: self._db.disconnect() # 日次バッチ処理中の場合、後続の処理は行わない - if batch_processing_flag == constants.BATCH_ACTF_BATCH_START: + if batch_processing_flag != constants.BATCH_ACTF_BATCH_START: return False # dump取得が正常終了していない場合、後続の処理は行わない if dump_status_kbn != constants.DUMP_STATUS_KBN_COMPLETE: diff --git a/ecs/jskult-batch-ultmarc-io/src/system_var/environment.py b/ecs/jskult-batch-ultmarc-io/src/system_var/environment.py index 4903ff01..30179dc7 100644 --- a/ecs/jskult-batch-ultmarc-io/src/system_var/environment.py +++ b/ecs/jskult-batch-ultmarc-io/src/system_var/environment.py @@ -19,6 +19,7 @@ JSK_DATA_SEND_FOLDER = os.environ['JSK_DATA_SEND_FOLDER'] JSKULT_BACKUP_BUCKET = os.environ['JSKULT_BACKUP_BUCKET'] JSK_BACKUP_FOLDER = os.environ['JSK_BACKUP_FOLDER'] DCF_DSF_SEND_FILE_NAME = os.environ['DCF_DSF_SEND_FILE_NAME'] +IMPORT_FILE_KEY = os.environ['IMPORT_FILE_KEY'] # 初期値がある環境変数 LOG_LEVEL = os.environ.get('LOG_LEVEL', 'INFO')