feat: 動作確認中に発覚したバグを修正。

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

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)

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:

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')