القائمة
OpenFlare / Wavelet：当新增或修改日志/分析用途表（节点访问日志、用户访问日志、可观测时序）、接入 internal/repository/logstore、切换日志主库、实现 PG/SQLite 回落，或判断一张表该走业务主库还是日志库时必须使用。
يُحدَّد Prompt الذي يراجع المصدر أولًا بشكل افتراضي. يمكنك التبديل إلى أمر مباشر أو تنزيل نسخة محلية.
اقرأ SKILL.md وأي ملفات مرافقة يعرضها SkillsMP قبل أن تقرر التثبيت.
التثبيت باستخدام Codex أو Claude انسخ هذا Prompt والصقه في Codex أو Claude أو مساعد آخر ليراجع صفحة Skill ويثبّتها لك.
يتجاوز الأمر المباشر Prompt المخصّص للمراجعة. افحص المصدر قبل تشغيله.
npx skills add https://github.com/Rain-kl/OpenFlare --skill logstoreيبقى الأمر في سطر واحد. مرّر أفقيًا لمراجعته كاملًا قبل النسخ.
تفضّل نسخة محلية؟ نزّل الملفات المتاحة حاليًا لدى SkillsMP.
Wavelet 项目专用：当业务需要上传文件、读取已上传文件、在 Worker/任务中程序化摄取字节流、选择存储引擎能力、或排查 w_uploads / 文件统计异常时必须使用。本技能指导 storage 与 upload 分层、upload.Ingest 策略选型、前后端接入与禁止旁路写表。
Wavelet 项目专用：当新增或修改自定义业务 API、新增业务路由、新增 service 层核心逻辑时必须使用。本技能指导包职责划分、推荐文件结构、路由解耦、Swagger 文档生成与质量门禁验证。
Wavelet 项目专用：新增或修改 Asynq 异步任务、后台任务、定时任务、任务元数据、TaskHandler、TaskParam、PayloadValidator、AppendLog、任务重试、任务执行记录或 Admin 任务 API 时必须使用。
استنادا إلى تصنيف SOC المهني
عرض SKILL.md
| 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。