Google Omni + Claude 4.8 Opus + eBay 청사진으로 월 1만 달러 수익 창출하는 법: 완벽한 이커머스 가이드

1import asyncio
2import base64
3import json
4import os
5import time
6import requests
7from google import genai
8from google.genai import types
9from anthropic import Anthropic
10
11# 환경 변수를 사용하여 AI 클라이언트 초기화
12anthropic_client = Anthropic(api_key=os.environ.get("ANTHROPIC_API_KEY"))
13google_client = genai.Client()
14
15EBAY_CLIENT_ID = os.environ.get("EBAY_CLIENT_ID")
16EBAY_CLIENT_SECRET = os.environ.get("EBAY_CLIENT_SECRET")
17
18def get_ebay_app_token(client_id, client_secret):
19    """애플리케이션 액세스 토큰을 획득하기 위한 공식 OAuth 흐름"""
20    creds = base64.b64encode(f"{client_id}:{client_secret}".encode()).decode()
21    try:
22        r = requests.post(
23            "https://api.ebay.com/identity/v1/oauth2/token",
24            headers={
25                "Authorization": f"Basic {creds}",
26                "Content-Type": "application/x-www-form-urlencoded"
27            },
28            data={
29                "grant_type": "client_credentials",
30                "scope": "https://api.ebay.com/oauth/api_scope"
31            },
32            timeout=15,
33        )
34        r.raise_for_status()
35        return r.json()["access_token"]
36    except Exception as e:
37        print(f"eBay OAuth 토큰 가져오기 오류: {e}")
38        return None
39
40def get_ebay_active_comps(query, token, limit=10):
41    """
42    라이브, 활성 경쟁자 리스팅을 가져옵니다.
43    참고: 판매 데이터는 제한됩니다. 이 단계는 엄격히 키워드 추출 및 상한 가격 분석을 위한 것입니다.
44    """
45    if not token:
46        return {}
47    try:
48        r = requests.get(
49            "https://api.ebay.com/buy/browse/v1/item_summary/search",
50            headers={
51                "Authorization": f"Bearer {token}",
52                "X-EBAY-C-MARKETPLACE-ID": "EBAY_US"
53            },
54            params={
55                "q": query,
56                "limit": limit,
57                "filter": "buyingOptions:{FIXED_PRICE},conditions:{USED|NEW}"
58            },
59            timeout=15,
60        )
61        return r.json() if r.status_code == 200 else {}
62    except Exception as e:
63        print(f"eBay Browse API 요청 중 오류 발생: {e}")
64        return {}
65
66async def simulate_phone_camera_stream(session):
67    """
68    라이브 휴대폰 카메라 스트림을 시뮬레이션합니다.
69    열려 있는 Gemini Live WebSocket 세션을 통해 JPEG 프레임(초당 1프레임)을 푸시합니다.
70    """
71    print("-> 라이브 카메라 스트림 시작됨...")
72    while True:
73        # 프로덕션 앱에서는 모바일 프레임 버퍼 또는 WebRTC 스트림으로 교체
74        if os.path.exists("live_frame.jpg"):
75            with open("live_frame.jpg", "rb") as f:
76                image_bytes = f.read()
77
78            await session.send(
79                input={"data": image_bytes, "mime_type": "image/jpeg"},
80                end_of_turn=False
81            )
82        await asyncio.sleep(1)
83
84async def main():
85    ebay_token = get_ebay_app_token(EBAY_CLIENT_ID, EBAY_CLIENT_SECRET)
86
87    config = types.LiveConnectConfig(
88        response_modalities=[types.LiveModality.TEXT],
89        system_instruction=types.Content(parts=[types.Part.from_text(
90            "당신은 물리적 제품 감지를 위한 AI 눈입니다. JPEG 프레임을 지속적으로 분석하십시오. "
91            "브랜드 제품을 명확히 보는 즉시 'brand' 및 'model_name' 필드가 포함된 짧은 JSON 문자열을 출력하십시오. "
92            "다른 것은 쓰지 마십시오."
93        )])
94    )
95
96    # Gemini Live에 WSS 연결 열기 (Google Omni의 핵심 엔진)
97    async with google_client.aio.live.connect(model="gemini-2.5-flash", config=config) as session:
98        print("=== 파이프라인 온라인 ===")
99        asyncio.create_task(simulate_phone_camera_stream(session))
100
101        async for response in session.receive():
102            if response.text:
103                try:
104                    omni_data = json.loads(response.text)
105                    query = f"{omni_data.get('brand')} {omni_data.get('model_name')}"
106                    print(f"\n[Omni Eyes] 감지됨: {query}")
107
108                    print(f"[eBay API] 활성 경쟁사 가져오는 중: {query}...")
109                    comps = get_ebay_active_comps(query, ebay_token)
110
111                    print("[파이프라인] 데이터 집계됨. Claude 4.8 Opus로 페이로드 전송 중...")
112                    # 집계된 페이로드와 시스템 프롬프트(파트 3)가 여기서 Claude로 전달됩니다.
113
114                except json.JSONDecodeError:
115                    continue
116
117if __name__ == "__main__":
118    asyncio.run(main())

1역할: 당신은 eBay 리스팅 전문가이자 재판매를 위한 SEO 카피라이터입니다.
2eBay 검색(Cassini)에서 순위를 매기고 전환율을 높이며, eBay 정책을 100% 준수하는 리스팅을 작성합니다.
3
4입력 (JSON):
5- item: {brand, model_name, category, estimated_condition, upc, attributes...}  // VISION 모델에서 가져옴 — 가설로 처리, 확정된 사실이 아님
6- seller_notes: 자유 텍스트 — 실제 상태, 결함, 측정값, 포함 품목  // 권위 있는 정보, item을 재정의함
7- active_comps: 현재 eBay 활성 리스팅 배열 (제목 + 가격)  // 키워드 및 가격 컨텍스트 전용
8- marketplace: 예: "EBAY_US" (기본값)
9- listing_language: 예: "en-US" (이 언어로 제목/세부사항/설명 작성)
10
11엄격한 규칙 (환각 방지 — 최우선 순위):
12- 절대 사실을 지어내지 마십시오. seller_notes 또는 item에 없는 한 측정값, 재료, 정품 여부, 모델 번호 또는 결함("결함 없음" 포함)을 주장하지 마십시오.
13- 필드를 알 수 없는 경우 "needs_from_seller"에 추가하고 설명에서 중립적인 플레이스홀더(예: "[측정: 겨드랑이에서 겨드랑이까지]")를 사용하십시오. 추측하지 마십시오.
14- 상태는 seller_notes와 정확히 일치해야 합니다. 절대 업그레이드하지 마십시오(명시적으로 명시되지 않는 한 "새 상품, 태그 있음" 안 됨). 알려진 모든 결함을 공개하십시오 — 정직함은 반품 및 INAD 클레임을 줄입니다.
15- seller_notes가 확인하지 않는 한 정품 보증("100% 정품")을 제공하지 마십시오.
16
17eBay SEO + 정책 규칙:
18- 제목: 최대 80자. 구매자가 실제로 입력하는 내용을 앞에 배치하고, 알려진 경우 다음 순서로 작성: 브랜드 -> 제품 라인/모델 -> 품목 유형 -> 주요 속성(크기, 색상, 소재, 핏) -> 간단한 상태. 구매자가 검색하는 1-2개의 고가치 동의어를 추가하십시오.
19  금지: 모두 대문자, 반복 단어, 이모지/기호, "L@@K" 스타일 스팸, 관련 없는 브랜드 키워드(키워드 스터핑은 정책 위반이며 순위를 낮춤), "스타일 / 영감을 받은 + 브랜드"(상표권 오용).
20- 품목 세부사항: 입력에서 정당화할 수 있는 모든 세부사항을 채우십시오(브랜드, 부서, 유형, 크기, 크기 유형, 색상, 소재, 스타일, 패턴, 모델, MPN, UPC, 제조 국가/지역, 특징, 빈티지 여부...). Cassini는 세부사항을 중요하게 평가합니다. 알 수 없는 경우 -> 생략하거나 needs_from_seller에 넣으십시오. 절대 조작하지 마십시오.
21- 설명: 모바일 우선, 스캔 가능한 일반 텍스트(~120-180단어). 주요 키워드를 자연스럽게 사용한 시작 문장(스터핑 금지) -> 상태 / 측정값 / 소재 / 포함 품목에 대한 짧은 줄 -> 하나의 짧은 신뢰 및 반품 문장. 혜택 중심적이고 정직하게 작성하십시오.
22- 가격 책정: active_comps에서 즉시 구매 가격 범위와 빠른 판매 가격을 제시하십시오. 기준이 활성 리스팅(경쟁)이며 판매 데이터가 아니므로 상한 추정치임을 명확히 밝히고, 리스팅 전에 Terapeak 판매 경쟁사와 확인할 것을 권장하십시오. 단일 가격을 보장된 것으로 제시하지 마십시오.
23
24출력: 엄격한 JSON만. 서문 없음, 마크다운 펜스 없음.
25{
26  "title": "",                       // <=80자, listing_language로 작성
27  "item_specifics": {},              // 키: 값 쌍, 정당화된 필드만
28  "description": "",                 // 일반 텍스트
29  "suggested_price": { "buy_it_now": 0.0, "quick_sale": 0.0, "currency": "USD", "basis": "active_comps_only" },
30  "keywords": [],                    // 활용한 추가 검색어
31  "confidence": "high|medium|low",   // seller_notes 대비 vision 추측에서 얼마나 많은 정보가 나왔는지 기반
32  "needs_from_seller": []            // 리스팅을 조작으로부터 보호하기 위해 누락된 정보
33}