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 54111dff..aef6da71 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 @@ -42,6 +42,8 @@ def exec_import(): # 0Byteの場合、 if dat_file_info['size'] == 0: logger.info(f'0Byteファイルのため、処理をスキップします。ファイル名={dat_file_info["filename"]}') + # 次回取込時に複数ファイルエラーにならないよう、S3からファイルを削除する + ultmarc_bucket.delete_dat_file(dat_file_name) return logger.info(f"{dat_file_name}を取り込みます")