From 79b526b472351abba381207e75f2703a74ed8713 Mon Sep 17 00:00:00 2001 From: OG T Date: Fri, 27 Mar 2026 09:33:13 +0800 Subject: [PATCH] =?UTF-8?q?fix(api):=20P0=20=E7=B5=B1=E4=B8=80=20Stream=20?= =?UTF-8?q?Key=20=E7=82=BA=20awoooi:signals?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修復 Producer/Worker/Webhooks 使用不同 Stream Key 導致訊息無法消費 Co-Authored-By: Claude Opus 4.5 --- apps/api/src/api/v1/webhooks.py | 3 ++- apps/api/src/workers/signal_worker.py | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/apps/api/src/api/v1/webhooks.py b/apps/api/src/api/v1/webhooks.py index 400c8f4fb..e86950f11 100644 --- a/apps/api/src/api/v1/webhooks.py +++ b/apps/api/src/api/v1/webhooks.py @@ -463,7 +463,8 @@ class AlertResponse(BaseModel): # ============================================================================= # Redis Stream 常量 -SIGNAL_STREAM_KEY = "stream:awoooi_signals" +# 2026-03-27 ogt: 統一 Stream Key 格式 (P0 修復) +SIGNAL_STREAM_KEY = "awoooi:signals" SIGNAL_STREAM_MAXLEN = 10000 # 防止 Stream 無限增長 diff --git a/apps/api/src/workers/signal_worker.py b/apps/api/src/workers/signal_worker.py index 523c55dfa..7faf6f90b 100644 --- a/apps/api/src/workers/signal_worker.py +++ b/apps/api/src/workers/signal_worker.py @@ -44,7 +44,8 @@ logger = structlog.get_logger(__name__) # Constants # ============================================================================= -STREAM_KEY = "stream:awoooi_signals" +# 2026-03-27 ogt: 統一 Stream Key 格式 (P0 修復) +STREAM_KEY = "awoooi:signals" CONSUMER_GROUP = "awoooi_workers" CONSUMER_NAME = f"worker_{socket.gethostname()}"