diff --git a/ecs/Dockerfile/dataimport/main.py b/ecs/Dockerfile/dataimport/main.py index 32e03ac0..dd0a17d0 100644 --- a/ecs/Dockerfile/dataimport/main.py +++ b/ecs/Dockerfile/dataimport/main.py @@ -123,13 +123,13 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf sql = f'{sql} NULL,' # システム項目:更新者 sql = f'{sql} NULL)' # システム項目:更新日時 + index += 1 + # ロードスキーマのトランザクション開始 with conn.cursor() as cur: cur.execute(sql) conn.commit() normal_count += 1 - - index += 1 except Exception as e: warning_count += 1 warning_info = f'{warning_info} {index} ロードスキーマ登録時にエラーが発生しました {line} {e}\n'