업비트 원화 마켓 24시간 자동매매 가이드

[ 취약한 동시 요청 (충돌 발생) ]
코루틴 A (BTC 매수) ──► nonce="1710000000100" ──┐
코루틴 B (ETH 매수) ──► nonce="1710000000100" ──┼──► 업비트 서버: "동일 Nonce 충돌! 동일 Nonce 충돌로 주문 거절" ❌
 
[ DashCloud 순차 큐잉 (안전) ]
코루틴 A, B 주문 생성 ──► [ 단일 비동기 주문 큐 ] ──► UUID v4 기반 고유 Nonce 생성 ──► 초당 10회 순차 집행 (100% 성공) ✅

import os
import time
import uuid
import hashlib
import jwt
import requests
import asyncio
import logging
from urllib.parse import urlencode, unquote
 
logger = logging.getLogger("UpbitClient")
 
class UpbitSafeClient:
    def __init__(self, access_key: str, secret_key: str):
        self.access_key = access_key
        self.secret_key = secret_key
        self.server_url = "https://api.upbit.com"
        self.last_order_time = 0.0
        self.min_order_interval = 0.1  # 초당 약 10회로 제한 (12회 한도 준수)
 
    def _generate_auth_headers(self, query_params: dict = None):
        """UUID v4 기반 무충돌 Nonce JWT 인증 토큰 생성"""
        payload = {
            "access_key": self.access_key,
            "nonce": str(uuid.uuid4()), # 타임스탬프 대신 UUID를 사용하여 충돌 원천 차단
        }
 
        if query_params:
            query_string = unquote(urlencode(query_params, doseq=True)).encode("utf-8")
            m = hashlib.sha512()
            m.update(query_string)
            query_hash = m.hexdigest()
            payload["query_hash"] = query_hash
            payload["query_hash_alg"] = "SHA512"
 
        jwt_token = jwt.encode(payload, self.secret_key, algorithm="HS512")
        return {"Authorization": f"Bearer {jwt_token}"}
 
    async def create_market_buy_order(self, market: str, price_krw: int):
        """
        원화 시장가 매수 (초당 12회 쿼터 준수 딜레이 적용)
        :param market: 마켓 코드 (예: "KRW-BTC")
        :param price_krw: 매수할 총 원화 금액 (최소 5,000원 이상)
        """
        if price_krw < 5000:
            raise ValueError("업비트 최소 주문 금액은 5,000원 이상이어야 합니다.")
 
        # 쿼터 준수를 위한 대기 시간 제어
        elapsed = time.time() - self.last_order_time
        if elapsed < self.min_order_interval:
            await asyncio.sleep(self.min_order_interval - elapsed)
 
        params = {
            "market": market,
            "side": "bid",       # 매수
            "price": str(price_krw),
            "ord_type": "price", # 시장가 매수
        }
        headers = self._generate_auth_headers(params)
 
        try:
            res = requests.post(f"{self.server_url}/v1/orders", json=params, headers=headers, timeout=5)
            self.last_order_time = time.time()
 
            # 업비트 잔여 쿼터 헤더 파싱 로깅
            remaining = res.headers.get("Remaining-Req", "")
            logger.debug(f"주문 응답 완료. 잔여 쿼터: {remaining}")
 
            if res.status_code == 201:
                order_data = res.json()
                logger.info(f"✅ 매수 성공 [{market}]: 주문 ID {order_data['uuid']}, 금액: {price_krw:,}원")
                return order_data
            else:
                logger.error(f"❌ 매수 실패 [{market}] ({res.status_code}): {res.text}")
                return None
        except Exception as e:
            logger.error(f"주문 통신 중 오류: {e}")
            return None

[ create_order 지정가 주문 접수 ] ──► 주문 UUID 로컬 기록
                 │
                 ▼
         [ 30초 타이머 가동 ]
                 │
         ┌───────┴────────────────────────┐
      (체결 완료)                       (미체결 잔존)
         │                                │
         ▼                                ▼
    [정상 익절 루프]              ┌─────────────────────────────────┐
                                  │ 1. cancel_order(UUID) 취소 요청 │
                                  │ 2. 취소 성공 확인 후 호가 재조정 │
                                  └─────────────────────────────────┘