用途:在本地端到端调试 PostHog signals 管道。管道流程为 emit_signals_from_fixture → signal-emitter → buffer-signals(5 秒刷新)→ safety_filter/flush_to_s3/grouping_v2 → 语义搜索与报告匹配 → 必要时 signal-report-summary 并启动 Docker 沙箱。
主要能力:从 JSON fixture 发射测试信号;用管理命令清理信号数据、查看管道状态、检查分组结果、导入预处理信号或报告;通过 Temporal UI(http://localhost:8081)与 REST API 列出工作流、查看历史(含 continued-as-new 的 runId);从对象存储(本地 MinIO)读取 JSONL 代理日志;用 docker ps/exec 检查临时沙箱容器。
必要用法:发射单条信号 DEBUG=1 python manage.py emit_signals_from_fixture --type zendesk --team-id 1 --offset 26 --limit 1;重新发射前先 DEBUG=1 python manage.py cleanup_signals --team-id 1 --yes;用 python manage.py signal_pipeline_status --team-id 1 --wait --expected-signals 1 --poll-interval 10 检查状态。
常见故障:SignalReport matching query does not exist 多因 .env 未设 CLICKHOUSE_DATABASE=posthog 导致清理未删旧 embedding;select_repository_activity 超时受 TASKS_INACTIVITY_TIMEOUT_SECONDS 控制;buffer-signals 空闲可能因信号发往已 continued-as-new 的旧运行,需重发。
限制:容器为临时性,任务结束即删除,须在运行时检查;日志与 embedding 表位置依赖本地环境配置。其余细节暂未提供。