Full Refresh를 안전하게 실행하기 위해서,
데이터베이스 트랜잭션 처리 시,
cur.execute("BEGIN;")
cur.execute("COMMIT;") # or cur.execute("END;")
으로 트랙잭션 시작과 끝을 명시하여 하나의 작업 단위로 묶어서 처리해야 합니다.
오류 사항 발생시,
cur.execute("ROLLBACK;")을 수행하여 트랜잭션을 이전 상태로 복구합니다.
'데브코스 데이터엔지니어링' 카테고리의 다른 글
| [Airflow] Airflow Connections와 Variables (1) | 2024.12.28 |
|---|---|
| [SQL] 테이블 레코드 삭제 delete from vs. truncate 차이 (0) | 2024.12.28 |
| Python 라이브러리 psycopg2로 PostgreSQL 데이터베이스 연결 (1) | 2024.12.28 |
| [Airflow] Apache Airflow PythonOperator 사용하기 (1) | 2024.12.27 |
| [Airflow] 도커 airflow 웹서버 포트 에러 (0) | 2024.12.27 |