Error 1997: 분산 DB의 트랜잭션과 관련 에러 대응

OperationalError: 1997: Attempted to interrupt transaction execution, but the outcome is unknown because the transaction was already in its commit phase. Please check if it succeeded.

CREATE TABLE tx_tracking ( transaction_id BINARY(16) NOT NULL, created_at DATETIME(6) DEFAULT NOW(6), PRIMARY KEY (transaction_id), SHARD KEY (transaction_id), SORT KEY (transaction_id) );

import singlestoredb as s2 import uuid import time def process_transaction(conn, business_data, max_backoff_sec=60): """ error 1997에 대한 transaction 가이드 코드입니다. - 멱등성 보장을 위한 transaction 재시도 시, UNIQUE 제약 및 동일한 transaction_id가 필수적입니다. - transaction은 아래 2가지 경우 재시도를 종료(더 이상 재시도하지 않음)합니다. - transaction이 에러 없이 정상적으로 커밋된 경우 - Duplicate Entry (Error 1062)가 발생한 경우 (원본 transaction이 이미 commit된 경우) - Duplicate Entry는 resolution에서 Commit으로 확정한 경우로 App단에서는 Rollback을 진행합니다. - 그 외의 실패(Error 1997, 1857 등)는 exponential backoff으로 재시도합니다. - 실제 코드에 반영할 경우, 무한 재시도가 되지 않도록 최대 시도 횟수를 지정하십시오. """ tx_id = uuid.uuid7().bytes attempt = 0 while True: cur = conn.cursor() try: cur.execute("BEGIN") cur.execute( "INSERT INTO tx_tracking (transaction_id) VALUES (%s)", (tx_id,) ) cur.execute( "INSERT INTO order_data (amount) VALUES (%s)", (business_data["amount"],), ) cur.execute("COMMIT") return True, tx_id except s2.IntegrityError as e: if e.errno == 1062: # 원본 트랜잭션이 resolution 과정에서 Commit 되었으므로 Rollback cur.execute("ROLLBACK") return True, tx_id raise except s2.OperationalError as e: err_code = e.errno # Error 1997(결과 미확정) 또는 1857(rollback 확정)은 backoff 후 재시도 print(f"[tx_id={tx_id.hex()}] attempt {attempt} 실패 " f"(error_code={err_code}), backoff 후 재시도") finally: try: cur.close() except Exception: pass attempt += 1 wait_sec = min(2 ** attempt, max_backoff_sec) time.sleep(wait_sec)