wooo/awoooi
1
1
Fork 0
Code Issues 2 Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

fix(api): P0 統一 Stream Key 為 awoooi:signals

Browse Source 
修復 Producer/Worker/Webhooks 使用不同 Stream Key 導致訊息無法消費

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
OG T
2026-03-27 09:33:13 +08:00
parent e34b0f2e9a
commit 79b526b472
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
apps/api/src/api/v1/webhooks.py
View File

@@ -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 無限增長

3
apps/api/src/workers/signal_worker.py
View File

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