メニュー
OpenFlare / Wavelet：当新增或修改日志/分析用途表（节点访问日志、用户访问日志、可观测时序）、接入 internal/repository/logstore、切换日志主库、实现 PG/SQLite 回落，或判断一张表该走业务主库还是日志库时必须使用。
デフォルトでは、最初にソースを確認する Prompt が選択されています。直接コマンドに切り替えるか、ローカルコピーをダウンロードすることもできます。
インストールを決める前に、SKILL.md と SkillsMP に表示されている付属ファイルをお読みください。
SOC 職業分類に基づく
Codex または Claude でインストール この Prompt をコピーして Codex、Claude、または他のアシスタントに貼り付けると、Skill ページを確認してインストールできます。
直接コマンドでは確認用 Prompt が省略されます。実行前にソースを確認してください。
npx skills add https://github.com/Rain-kl/OpenFlare --skill logstoreコマンドは1行のまま表示されます。コピー前に横へスクロールして全体を確認してください。
ローカルで確認しますか？SkillsMP が現在取得できるファイルをダウンロードできます。
SKILL.md を表示中
Wavelet 项目专用：当业务需要上传文件、读取已上传文件、在 Worker/任务中程序化摄取字节流、选择存储引擎能力、或排查 w_uploads / 文件统计异常时必须使用。本技能指导 storage 与 upload 分层、upload.Ingest 策略选型、前后端接入与禁止旁路写表。
Wavelet 项目专用：当新增或修改自定义业务 API、新增业务路由、新增 service 层核心逻辑时必须使用。本技能指导包职责划分、推荐文件结构、路由解耦、Swagger 文档生成与质量门禁验证。
Wavelet 项目专用：新增或修改 Asynq 异步任务、后台任务、定时任务、任务元数据、TaskHandler、TaskParam、PayloadValidator、AppendLog、任务重试、任务执行记录或 Admin 任务 API 时必须使用。
| name | logstore |
| description | OpenFlare / Wavelet：当新增或修改日志/分析用途表（节点访问日志、用户访问日志、可观测时序）、接入 internal/repository/logstore、切换日志主库、实现 PG/SQLite 回落，或判断一张表该走业务主库还是日志库时必须使用。 |
开始前阅读根目录 AGENTS.md。DDL 用 database-migration；高频写入队列用 clickhouse-batchwriter；切换任务用 new-async-task。本技能只回答：这张表是不是日志表，以及如何接入可切换的日志主库。
设计背景见 日志存储解耦。
日志表同时满足：
不要做成日志表：Zone、节点、配置版本、任务执行、上传元数据。这些走主库 repository。
当前日志域：
| 域 | 接口 | 表 |
|---|---|---|
| 节点访问日志 | AccessLogStore | of_node_access_logs |
| 可观测 | ObservabilityStore | of_node_metric_snapshots / of_node_edge_health / of_node_obs_frps / of_node_obs_frpc |
| 用户访问审计 | UserAccessLogStore | w_user_access_logs |
| 层级 | 路径 | 职责 |
|---|---|---|
| 抽象 | internal/repository/logstore | 接口 + Active/BuildForMigration；apps 只面向这里或 repository 门面 |
| CH 实现 | logstore/clickhouse_store.go 委托 analytics | 原生批量 + 现有聚合 SQL |
| 主库实现 | logstore/postgres_store.go | PG（按月分区）与 SQLite（普通表）共用 GORM |
| Model | internal/model/analytics | 实体与批量 SQL，无 IO |
| 入队 | chwriter / risk_control + batchwriter | flush 调 logstore BatchInsert*；CH 入队经 hooks |
| 切换 | of_log_db_switch | 冻结 → chwriter.Drain → 逐表复制 → 翻转 |
| 约束 | logstore/imports_test.go | apps 禁止 import repository/analytics |
log_database 只能是「随主库」或 clickhouse。log_database / log_db_migration 受保护。
internal/model/analytics）：TableName + InsertColumns / BatchInsertSQL。MergeTree + toYYYYMM；PG PARTITION BY RANGE(时间列)（主键含分区键）；SQLite 普通表。不要在主库建 CH 物化视图，聚合实时算。AccessLogStore / ObservabilityStore / UserAccessLogStore 就不要再拆包。新域才新增接口并放进 Store。BatchInsert（含 ensureWritable）、业务查询、ListForMigration、MigrationRange、DeleteAll、DeleteBefore、EnsurePartitions（仅 PG 预建）。analyticsrepo；GORM 共用一套，方言 SQL 放 dialect_*.go。零值 id 用 idgen.NextUint64ID()。buildStore：CH / GORM 两分支都挂上。batchwriter；FlushFunc → logstore.Active。节点日志/可观测走 SetAccessLogHooks / SetObservabilityHooks，不要让 apps 碰 ChConn。clearTarget + copy* 增加该表；源数据不删，失败不翻转。log_retention_days_*；性能指标走 metric_retention_days。不要擅自共用错误的 TTL。analytics 或 infra/persistence（batchwriter/idgen 除外）的 import 必须失败。analyticsrepo / db.ChConn / db.ChDB 做日志读写PrepareBatchlog_database / log_db_migrationgo test ./internal/repository/logstore ./internal/repository/analytics
go test ./internal/apps/openflare/... ./internal/apps/admin/logs ./internal/apps/admin/status
make swagger
make code-check
对照：of_node_access_logs 或 w_user_access_logs 的 model、三库 goose、logstore 双实现、chwriter/risk_control flush、LogDBSwitchHandler。