fix(realestate): compose INTERNAL_API_KEY(배포 401 방지) + 매칭·알림 공유락(중복 텔레그램 방지)

- docker-compose.yml realestate-lab environment에 INTERNAL_API_KEY/NAVER_PAGE_LIMIT 누락 추가
  (verify_internal_key 항상 401 → 워커 계약 전체 마비 방지, sibling image/video/music/insta-lab과 동형)
- pipeline_lock.py 신설: cron _run_listing_pipeline과 워커 listings_ingest가
  run_listing_matching()+notify_new_listings() 임계구역을 공유 threading.Lock으로 직렬화
  (동시 실행 시 동일 매물 중복 텔레그램 발송 방지). 느린 collect는 락 밖 유지.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01EqCYBhvTcdeCTUDX3RhWx9

realestate-lab/app/internal_router.py

@@ -11,6 +11,7 @@ from .lawd_codes import naver_cortar
 from .listing_collector import _parse_naver_article
 from .listing_matcher import run_listing_matching
 from .notifier import notify_new_listings
+from .pipeline_lock import match_notify_lock
 
 logger = logging.getLogger("realestate-lab")
 router = APIRouter()
@@ -61,7 +62,8 @@ def listings_ingest(body: ListingsIngest):
                 logger.warning("네이버 ingest 파싱 실패: %s", e)
     matched = 0
     if received:
-        run_listing_matching()
-        noti = notify_new_listings()
-        matched = int(noti.get("sent", 0)) if isinstance(noti, dict) else 0
+        with match_notify_lock:
+            run_listing_matching()
+            noti = notify_new_listings()
+            matched = int(noti.get("sent", 0)) if isinstance(noti, dict) else 0
     return {"received": received, "new": new, "matched": matched}

realestate-lab/app/main.py

@@ -23,6 +23,7 @@ from .matcher import run_matching
 from .notifier import notify_new_matches, notify_new_listings
 from .listing_collector import collect_listings
 from .listing_matcher import run_listing_matching, compute_safety, compute_valuation
+from .pipeline_lock import match_notify_lock
 from . import finance_rules
 from .finance_rules_config import DISCLAIMER
 from .models import (
@@ -73,7 +74,10 @@ def _run_listing_pipeline():
     if not _listing_collect_lock.acquire(blocking=False):
         logger.info("매물 수집 이미 진행 중 — 건너뜀"); return
     try:
-        collect_listings(); run_listing_matching(); notify_new_listings()
+        collect_listings()
+        with match_notify_lock:
+            run_listing_matching()
+            notify_new_listings()
     finally:
         _listing_collect_lock.release()
 

realestate-lab/app/pipeline_lock.py

@@ -0,0 +1,5 @@
+"""매물 매칭+알림 임계구역 직렬화 락 — cron 파이프라인과 워커 ingest가 공유해
+run_listing_matching()+notify_new_listings() 동시 실행(중복 텔레그램)을 방지한다."""
+import threading
+
+match_notify_lock = threading.Lock()