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()}"