行情归档的「调度台 + 记账本」：全局单例的采集 DO 记着在采哪些币、每条序列采到哪、下一步跑什么任务、HL 权重这一分钟还剩多少，以及盘中检查要盯的价位和临时拉到的 1m。
不存行情本身：K 线 / 资金费 / 市场参数 / 覆盖范围索引都在 R2 桶 MARKET_ARCHIVE（只追加，更正走数据修订号）；行情权威是 Hyperliquid。部署、模拟账户、成交都在各自的 StrategyOwner DO（strategy-owner-do），这里只存所有者报上来的副本。
schema_migrations.applied_at（迁移 runner 写 ISO 字符串）。minute_candles 的 OHLCV、intrabar_watches.below / above）一律存十进制字符串，读出后用 safeBN 比较，不经 Number。active / open_pending / archive / archived），库里没有 CHECK，只由仓储写 0 或 1。ctx.storage.sql）；写路径里的 batch 指包在 storage.transactionSync 里，single 指一条或几条独立的 sql.exec（不包事务，但同步执行、中间没有 await）。mainnet（ARCHIVE_COLLECTOR_NAME）。production（ARCHIVE_ROLE = collector）与 staging（reader）各有一个同名实例、各一个库；staging 不采集，只为本环境的部署做盘中检查，所以采集相关的表在 staging 为空。ARCHIVE_COLLECTOR_SCHEMA_MIGRATIONS 只增不改，DO 构造函数里由 migrateStrategySchema 同步跑完才接请求。*/15 * * * *，只有 production）调 tick → jobsForTick 读 coins（在采）、deployed_coins（先抓）、reconciliations（已对的跳过），enqueue 进 jobsdrainCollection 循环：nextDueJob 取任务，读 weight_spends 过去 60 秒的账，checkShare 不放行就把 alarm 拨到能放行的时刻series 游标打一次 HL candleSnapshot，recordSpend 记一笔 weight_spends（来源 collection）saveSeries 推进游标；15m 之后顺带把 1h / 4h / 1d 能聚合的桶聚合并推进各自游标completeJob 删任务；本轮有游标变动就重写 R2 覆盖范围索引（可回测区间）universe 任务打 meta（20 权重）→ diffMarkets 对比 coins，发现新币events（market_revised）enqueue 一次性回补：15m / 1h / 4h / 1d 原生 K 线 + 资金费全量（优先级 4）syncMarkets 插入 coins（active = 1）replaceDeployments：整组替换 deployed_coins 与 intrabar_watches，有监视就把 alarm 拨到下一分钟收盘后 2 秒runIntrabarCheck：币少按 1m 拉（每币 20 权重），币多改 allMids 每 6 秒采样（2 权重）；结果写 minute_candles + minute_coverage，权重记进 weight_spends（来源 intrabar）intrabar_watches：1m 低点 ≤ below 或高点 ≥ above 才按所有者分组唤醒，带上那根开盘以来的 1mresolveWatch 改行（回 null 则两侧清空、留行防重复唤醒）archive = 1 的原生 1m 追加进 R2 并 markArchived；pruneMinutes 裁掉不再需要的 1mreconciliations 里没有的 币 × 周期 × 天 排 reconcile 任务（日终后 30 分钟起，优先级 5）attempts +1），满 8 次记 reconcile_skipped 放弃events（reconcile_mismatch，最多列 20 条）markReconciled 写 reconciliations，之后不再排MARKET_ARCHIVE。游标总在 R2 写成功之后才推进，重跑最多重抓一次，不会漏。weight_spends，source 区分。放行要同时过「本来源那一份」和「合计」两道（checkShare）；有在盯的部署时 15m 采集让出盘中那 300。依据 [HL rate limits](https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/rate-limits-and-user-limits)。jobs.key 由 jobKey 生成，一条序列同时只有一个任务；任务按游标决定从哪抓，所以 Cron 漏几轮也只是下一个任务多抓几根。deployed_coins 与 intrabar_watches 都按 owner 先删后插，不做增量对账——报告是幂等的，丢一次下次补上。两张表各自一个事务，不在同一事务里。safeBN（金融算术全程 BigNumber）；SQL 里从不对价格做比较或排序。通用语言（术语定义）以 contexts/strategy/CONTEXT.md 为准，这里不重复。
coinsMarketSpec contexts/strategy/src/domain/value-objects/marketData.ts — 币名 + szDecimals + maxLeverage + 保证金分档一个币一行，下架不删只置 active = 0 | SQL | syncMarkets（collectorRepository.ts），全仓无 DELETE FROM coins |
| 先写 R2 市场参数（变了生成新修订）、排新币回补，最后才落币表——中途失败重跑仍能认出同一批新币 | 领域代码 | runUniverse（application/archive/collector.ts） |
| 参数是否变化以三列（含分档 JSON）整体比较 | SQL | sameMarket / diffMarkets（collectorRepository.ts） |
只采 mainnet 主 DEX perp；市场参数的权威是 HL meta | 外部 | Hyperliquid（createMainnetMarketData） |
active = 0）active = 1，不重排回补）seriesSeriesCursor / SeriesId / coverageOf contexts/strategy/src/domain/archive/coverage.ts — 游标 → 可回测区间acceptCandles / acceptFunding / needsNativeFill contexts/strategy/src/domain/archive/continuity.ts — 去重、缺口判定、continuousSince 推进| 每币每周期一条 K 线序列、每币一条资金费序列（资金费 interval = ''） | 数据库 | PK(coin, kind, interval) + seriesKey |
| 先追加 R2 再推进游标：游标指向的行一定已在归档里 | 领域代码 | runCandles / runFunding / aggregateLonger（collector.ts） |
first_time ≤ continuous_since ≤ last_time，且都是序列里真实存在的行 | 领域代码 | acceptCandles（continuity.ts） |
| 序列有变动就重写 R2 覆盖范围索引 | 领域代码 | drainCollection 末尾 writeCoverage(coverageOf(allSeries())) |
jobs + reconciliationsCollectionJob / jobKey / jobsForTick / JOB_PRIORITY contexts/strategy/src/domain/archive/collectionJobs.ts — 排期表与去重键reconcileCandles contexts/strategy/src/domain/archive/reconciliation.ts — 聚合 K 线 vs HL 原生逐根比对| 同一序列同时只排一个任务 | 数据库 | jobs.key PK（键由 jobKey 生成） |
| 重复排入取更高优先级与更早到期，不降级不推迟 | SQL | enqueue 的 ON CONFLICT DO UPDATE … MIN(…) |
| 取任务顺序 = 优先级 → 到期 → 键 | SQL | nextDueJob + 索引 jobs_by_order |
| 失败退避 1 分钟起翻倍、上限 30 分钟；被 HL 429 限流时整队停一个窗口 | 领域代码 | runSafely（collector.ts） |
| 对账只记告警、不自动改归档；跑完比对即记已对账 | 领域代码 | runReconcile（collector.ts） |
| 每币每周期每天至多一条已对账记录 | 数据库 | PK(coin, interval, day) + INSERT OR REPLACE |
nextDueJob + checkShare）completeJobrescheduleJob）due_at 到期reconcile_skipped 后放弃weight_spendshlInfoWeight / checkBudget / checkShare / weightShares contexts/strategy/src/domain/archive/throttle.ts — 权重表、窗口判定、两类来源的分额metered contexts/strategy/src/application/archive/collector.ts — 打 HL 并记账的唯一入口| 过去 60 秒的权重 + 本次预估 ≤ 预算才放行；production 合计 600 / 分钟，有在盯的部署时盘中 300、15m 让到 300；staging 合计 100 | 领域代码 | checkShare / weightShares（throttle.ts） |
| 每次 HL 请求（含失败）都记一笔 | 领域代码 | metered（collector.ts） |
| 只保留最近两个窗口（120 秒）的流水 | SQL | recordSpend 里的 DELETE … WHERE at <= ? |
| HL 的真实额度按出口 IP 合并计（Bot 等其他 Worker 同出口），本账只管本 DO 的份额 | 外部 | Hyperliquid REST rate limit |
deployed_coinsDeployedCoinsRegistry / DeploymentReport contexts/strategy/src/application/archive/ports.ts — 整组替换的报告端口| 按所有者整组替换，同一所有者同一币只一行 | SQL | replace（deployedCoinsRegistry.ts）transactionSync + PK(owner, coin) |
| 报告失败只记日志，不影响部署（收盘那一步兜底） | 领域代码 | deploymentReporter（apps/strategy/src/owner/StrategyOwner.ts） |
intrabar_watchesIntrabarWatch / hasLevels / watchTriggered contexts/strategy/src/domain/archive/intrabarWatch.ts — 监视形状与命中判定（BigNumber 比较）runIntrabarCheck contexts/strategy/src/application/archive/intrabar.ts — 一轮：拉 1m / 采样 → 比对 → 唤醒 → 归档 → 裁剪| 一个部署同时只盯一根 | 数据库 | PK(owner, deployment_id) |
| 同一部署同一根已由所有者定下的区间，不被再次报来的「开盘待定」覆盖 | SQL | replaceWatches（intrabarRepository.ts）transactionSync 内先读 open_pending = 0 的行 |
| 所有者答「没有要盯的」也留行（两侧 NULL），同一根不再唤醒 | SQL | resolveWatch |
| 开盘以来 1m 收录不完整就不比，留给收盘那一步兜底 | 领域代码 | wakeTriggered（intrabar.ts） |
resolveWatch）replaceWatches）minute_coverage + minute_candlesMinuteCoverage / candleFetchPlan / sampledCoverage / mergeMidSample / intrabarMode contexts/strategy/src/domain/archive/intrabarWatch.ts — 从哪接着拉、采样怎么并成 1m、按 1m 拉还是 allMidsArchiveCandle contexts/strategy/src/domain/value-objects/marketData.ts — time + OHLCV（十进制字符串）| 1m 行与收录范围在同一事务里写入 / 裁剪 | SQL | saveMinutes / pruneMinutes 的 transactionSync |
| 要归档但还没归档的行不会被裁掉 | SQL | pruneMinutes：WHERE time < ? AND (archive = 0 OR archived = 1) |
| 只有 HL 原生 1m 进归档，合成行（allMids 采样）不进 | 领域代码 | sampleMids 传 archive = false；fetchMinutes 传 writer !== null（intrabar.ts） |
archive 只升不降 | SQL | saveMinutes 的 MAX(minute_candles.archive, excluded.archive) |
| 只写已收盘的分钟（拉到的进行中那根丢弃）；合成行例外，写的就是当前分钟 | 领域代码 | fetchMinutes 的 row.time < currentMinute 过滤 |
markArchived）archive 取 MAX）pruneMinutes：早于本整点且不再被在盯的监视需要eventsArchiveEvent / ARCHIVE_EVENT_KINDS contexts/strategy/src/application/archive/ports.ts — 事件形状与种类| 只留最近 2000 条 | SQL | recordEvent 里按 MAX(id) - EVENT_RETENTION 删除 |
| 事件不含用户信息（所有者 / 部署 ID 不进） | 领域代码 | record / recordFailure（collector.ts / intrabar.ts） |
schema_migrationsmigrateStrategySchema contexts/strategy/src/infrastructure/sqlite/migrate.ts — 与 StrategyOwner DO 共用的 runner| 版本从 1 起连续，每个版本独立事务，失败整体回滚并抛错（DO 构造失败） | SQL | migrateStrategySchema 的 transactionSync |
| 已发布的迁移只增不改 | 领域代码 | apps/strategy 的迁移快照测试 |
保证方：数据库 约束 / 索引 / 触发器 SQL 仓储里的条件写 / batch 领域代码 domain 层规则 外部 链上等外部权威
| 操作 | 原子性 | coins | deployed_coins | events | intrabar_watches | jobs | minute_candles | minute_coverage | reconciliations | schema_migrations | series | weight_spends |
|---|---|---|---|---|---|---|---|---|---|---|---|---|
| syncMarkets contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts 新币 INSERT、参数变了或重新上架 UPDATE、不在列表里的置 active = 0；多条语句，未包事务 | single | ● | ||||||||||
| saveSeries contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts UPSERT 整个游标 | single | ● | ||||||||||
| enqueue contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts 逐个 UPSERT，冲突时 priority / due_at 取 MIN，attempts 不动 | single | ● | ||||||||||
| completeJob contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts 按键删除 | single | ● | ||||||||||
| rescheduleJob contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts 改 due_at 与 attempts | single | ● | ||||||||||
| markReconciled contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts INSERT OR REPLACE | single | ● | ||||||||||
| recordSpend contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts 插入一笔，顺带删掉 120 秒以前的流水 | single | ● | ||||||||||
| recordEvent contexts/strategy/src/infrastructure/sqlite/collectorRepository.ts 插入一条，顺带裁到最近 2000 条；DO 外壳另打一份到 Workers Logs | single | ● | ||||||||||
| DeployedCoinsRegistry.replace contexts/strategy/src/infrastructure/sqlite/deployedCoinsRegistry.ts 删该所有者全部行再插入去重后的币 | batch | ● | ||||||||||
| replaceWatches contexts/strategy/src/infrastructure/sqlite/intrabarRepository.ts 删该所有者全部行再插入；已定区间的同一根保留旧区间 | batch | ● | ||||||||||
| resolveWatch contexts/strategy/src/infrastructure/sqlite/intrabarRepository.ts 按 owner + 部署 + bar_from 改区间、open_pending = 0；不是这一根则不命中 | single | ● | ||||||||||
| saveMinutes contexts/strategy/src/infrastructure/sqlite/intrabarRepository.ts 1m 逐行 UPSERT + 收录范围 UPSERT | batch | ● | ● | |||||||||
| markArchived contexts/strategy/src/infrastructure/sqlite/intrabarRepository.ts R2 追加成功后，把该币整点以前 archive = 1 的行置 archived = 1 | single | ● | ||||||||||
| pruneMinutes contexts/strategy/src/infrastructure/sqlite/intrabarRepository.ts 删旧 1m；收录末端早于界限的删掉，起点早于界限的推到界限 | batch | ● | ● | |||||||||
| migrateStrategySchema contexts/strategy/src/infrastructure/sqlite/migrate.ts 每个版本： up + 版本行同一事务 | batch | ● |
| 本库字段 | 对应 | 说明 |
|---|---|---|
deployed_coins.owner | apps/strategy StrategyOwner DO 的 id（ctx.id.toString()） | 是 DO id 的 hex，不是 DO 名（DO 名才是 USER_DB 的 users.user_id） |
intrabar_watches.owner | apps/strategy StrategyOwner DO 的 id | 唤醒时 STRATEGY_OWNER.idFromString(owner).checkIntrabar(…) |
intrabar_watches.deployment_id | strategy-owner-do deployments.id | 不同 DO 的库，没有外键 |
coins.coin | Hyperliquid 主 DEX meta.universe[].name | 参数与分档同时写进 R2 MARKET_ARCHIVE 的市场参数修订 |
series.last_time | R2 MARKET_ARCHIVE 的 K 线 / 资金费分块与覆盖范围索引 | 游标是归档进度；覆盖范围索引由全部游标派生，回测读它求可回测区间 |
minute_candles.archived | R2 MARKET_ARCHIVE 的 1m 分块（按 UTC 日） | 只有 production 写 |
weight_spends.weight | Hyperliquid REST 权重限额（按出口 IP） | https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/rate-limits-and-user-limits |
events.kind | Workers Logs archive_<kind> | 同一事件结构化打日志，库里只留近 2000 条 |
| 表 | 规则 |
|---|---|
coins | 永不删除；下架只置 active = 0 |
series | 永不删除（无删除路径）；停采币的游标保留，可回测区间仍有效 |
jobs | 任务完成即删（completeJob）；失败 / 稍后再跑的留在队里改 due_at |
reconciliations | 永不删除（无清理路径）；排期只回看最近 2 天，更早的行不再被读，随时间按 币数 × 3 周期 × 天数 增长 |
weight_spends | 每次 recordSpend 顺带删掉 at ≤ 本笔 − 120 秒（2 × WEIGHT_WINDOW_MS）的行 |
events | 每次 recordEvent 顺带裁到最近 2000 条（EVENT_RETENTION，按 id） |
deployed_coins | 所有者每次报告整组替换，空组即删光该所有者的行；没有 TTL，所有者 DO 不再报告时行会残留 |
intrabar_watches | 所有者每次报告整组替换；收盘后的行不删（读时按 bar_to 过滤），直到该所有者下次报告。没有 TTL |
minute_candles | 每轮盘中检查末尾 pruneMinutes：删早于 min(本整点, 在盯监视最早的 bar_from) 且已归档或不用归档的行 |
minute_coverage | 随 pruneMinutes 一起：收录末端早于界限的删行，起点早于界限的推到界限 |
schema_migrations | 永不删除 |
| 字段 | 级别 | 说明 |
|---|---|---|
intrabar_watches.below | 内部 | 用户部署的止损 / 强平价位，不对外展示，也不写进事件 |
intrabar_watches.above | 内部 | 用户部署的止盈价位，同上 |
intrabar_watches.owner | 内部 | DO id，可间接关联到用户；事件里刻意不记 |
deployed_coins.owner | 内部 | 同上 |
minute_candles.close | 公开 | HL 公开行情（或由公开 allMids 合成），OHLCV 各列同级 |
coins.margin_tiers | 公开 | HL meta 公开的市场参数 |
0003 绿色迁移号表示该字段由后续迁移 ALTER TABLE 加入。点表名展开。
universe 任务刷新；active = 1 的币每轮都排 15m / 资金费任务。行不删除：下架只置 active = 0。参数列用来和最新的 HL meta 比，变了就去 R2 写新的市场参数修订。| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKcoin | TEXT | PK | HL 主 DEX perp 的币名（如 BTC），也是各序列 / 任务键里的币 | 1 |
| sz_decimals | INTEGER | NOT NULL | 数量精度（HL szDecimals）；价格小数位上限 = 6 − szDecimals | 1 |
| max_leverage | INTEGER | NOT NULL | 最高杠杆（HL maxLeverage） | 1 |
| active | INTEGER | NOT NULL | 1 = 还在 HL 列表里、在采；0 = 已从列表消失、停采（重新出现时置回 1） | 1 |
| first_seen_at | INTEGER | NOT NULL | 第一次在列表里见到它的时刻；之后不变 | 1 |
| updated_at | INTEGER | NOT NULL | 参数或 active 最近一次变化的时刻（参数没变不刷新） | 1 |
| margin_tiers | TEXT | 保证金分档的 JSON（MarketSpec.marginTiers，按下限升序）。NULL = v2 迁移前写下的旧行；下次刷新时与新 JSON 不等，被当作「市场参数变了」补写一次修订 | 2 |
| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKowner | TEXT | PK | 报告方 StrategyOwner DO 的 id（ctx.id.toString()，hex），不是用户 ID | 3 |
| PKcoin | TEXT | PK | 该所有者有活跃部署的币 | 3 |
recentEvents 回看几天。| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKid | INTEGER | PK | 自增序号；裁剪按它保留最新的 2000 条，读也按它倒序 | 1 |
| at | INTEGER | NOT NULL | 发生时刻 | 1 |
| kind | TEXT | NOT NULL | ARCHIVE_EVENT_KINDS 之一；读出时认不出的（旧版本写的）跳过 | 1 |
| coin | TEXT | 相关币；NULL = 不针对单个币（如盘中检查失败） | 1 | |
| interval | TEXT | 相关周期；NULL = 不针对周期（资金费、列表刷新、盘中检查） | 1 | |
| detail_json | TEXT | NOT NULL | 计数 / 时刻 / 阶段 / 异常类名等元数据的 JSON 对象；不含所有者、部署 ID 等用户信息 | 1 |
below 或最高价 ≥ above 就唤醒所有者。一个部署同时只有一行。所有者整组替换，所有者答完后按 resolveWatch 就地改区间；那根收盘后行不删，直到所有者下次报告把它换掉。| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKowner | TEXT | PK | 报告方 StrategyOwner DO 的 id；唤醒时用 idFromString 找回 | 4 |
| PKdeployment_id | TEXT | PK | 所有者库里的部署 ID | 4 |
| coin | TEXT | NOT NULL | 部署交易的币 | 4 |
| bar_from | INTEGER | NOT NULL | 那根的开盘时刻；只比对 [bar_from, bar_to) 里已收盘的 1m | 4 |
| bar_to | INTEGER | NOT NULL | 那根的收盘时刻；收盘后再留 2 分钟能比，之后 45 分钟内 allMids 模式仍接着采样 | 4 |
| below | TEXT | 下侧价位（十进制字符串，止损 / 强平等）；NULL = 这一侧没有价位 | 4 | |
| above | TEXT | 上侧价位（十进制字符串，止盈等）；NULL = 这一侧没有价位。两侧都 NULL 且非开盘待定 = 所有者答过「这一根没有要盯的」，留行防重复唤醒 | 4 | |
| open_pending | INTEGER | NOT NULL | 1 = 开盘要先成交市价单，价位要看开盘价：有一分钟就唤醒，由所有者算出区间后置 0。同一部署同一根已定过区间的，所有者再报「开盘待定」不会把它改回 1 | 4 |
due_at 留在队里。| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKkey | TEXT | PK | 去重键（jobKey）：universe / candles:<coin>:<interval> / funding:<coin> / reconcile:<coin>:<interval>:<day> | 1 |
| job_json | TEXT | NOT NULL | CollectionJob 的 JSON；读出时按 zod 判别联合校验。重复排入不覆盖它（键相同，内容也相同） | 1 |
| priority | INTEGER | NOT NULL | 数值越小越先跑：0 刷新列表 · 1 有部署的币的 15m · 2 其余 15m · 3 资金费 · 4 新币回补 · 5 对账（JOB_PRIORITY） | 1 |
| due_at | INTEGER | NOT NULL | 最早可跑的时刻；排入时一般是本轮收盘 + 5 秒，失败后按指数退避（1 分钟起、上限 30 分钟）后移 | 1 |
| attempts | INTEGER | NOT NULL | 连续失败 / 等待前置条件的次数，排入时为 0。分页没拉完重排时清零；对账「归档还没收录到那天」每等一次 +1，满 8 次放弃 | 1 |
| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKcoin | TEXT | PK | 币名 | 4 |
| PKtime | INTEGER | PK | 这一分钟的开盘时刻 | 4 |
| open | TEXT | NOT NULL | 开盘价（十进制字符串）；合成行 = 这一分钟第一笔采样 | 4 |
| high | TEXT | NOT NULL | 最高价；合成行 = 采样里的最高 | 4 |
| low | TEXT | NOT NULL | 最低价；合成行 = 采样里的最低 | 4 |
| close | TEXT | NOT NULL | 收盘价；合成行 = 最近一笔采样 | 4 |
| volume | TEXT | NOT NULL | 成交量；合成行固定 "0"（allMids 不给成交量） | 4 |
| archive | INTEGER | NOT NULL | 1 = 要写进 R2 行情归档（只有 production 按 1m 拉到的 HL 原生行）；0 = 合成行或 staging 拉到的行，不归档。同一分钟重写时取较大值，不会从 1 降回 0 | 4 |
| archived | INTEGER | NOT NULL | 1 = 已追加进 R2（markArchived）；新插入的行为 0，重写已有行时不改它 | 4 |
[covered_from, covered_through)：其中已收盘的分钟都拉过 / 采过（没成交的分钟可以没有行）。盘中检查据此决定从哪接着拉，以及某根开盘以来的数据够不够比。| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKcoin | TEXT | PK | 币名 | 4 |
| covered_from | INTEGER | NOT NULL | 收录起点（分钟开盘时刻）；接不上要的起点时从那里重新算起，裁剪时跟着后移 | 4 |
| covered_through | INTEGER | NOT NULL | 收录到哪一分钟（不含，通常是当前那一分钟） | 4 |
| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKcoin | TEXT | PK | 币名 | 1 |
| PKinterval | TEXT | PK | 聚合周期（1h / 4h / 1d） | 1 |
| PKday | INTEGER | PK | UTC 日 00:00 的毫秒时刻 | 1 |
| done_at | INTEGER | NOT NULL | 对完账的时刻。没有可对的序列（游标为空）也直接记上 | 1 |
up 同一个事务写入。| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKversion | INTEGER | PK | 迁移版本号（从 1 连续递增） | 1 |
| applied_at | TEXT | NOT NULL | 执行时刻，ISO 字符串（本库唯一的 TEXT 时间） | 1 |
| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKcoin | TEXT | PK | 币名 | 1 |
| PKkind | TEXT | PK | candles 或 funding | 1 |
| PKinterval | TEXT | PK | K 线周期（15m / 1h / 4h / 1d）；资金费序列固定为空串 '' | 1 |
| first_time | INTEGER | NOT NULL | 归档里第一行的时刻（K 线开盘 / 资金费结算时刻）；回补定下后基本不变 | 1 |
| last_time | INTEGER | NOT NULL | 最后一行的时刻；下次从它之后接着抓，长周期聚合也从这里往后推 | 1 |
| continuous_since | INTEGER | NOT NULL | 从这一行起到 last_time 连续无缺口。15m 出现补不回来的缺口时跳到缺口之后；长周期的桶早于它（落在缺口里）就改抓 HL 原生 | 1 |
| updated_at | INTEGER | NOT NULL | 游标最近一次推进的时刻 | 1 |
source 分开限额。| 字段 | 类型 | 约束 | 含义 | 迁移 |
|---|---|---|---|---|
| PKid | INTEGER | PK | 自增流水号，只用来区分同一毫秒的多笔 | 1 |
| at | INTEGER | NOT NULL | 请求发起的时刻（不是响应时刻） | 1 |
| weight | INTEGER | NOT NULL | 按实际返回条目数算的权重（hlInfoWeight）；请求失败也按基础权重记一笔，因为 HL 照样计数 | 1 |
| source | TEXT | NOT NULL · DEFAULT 'collection' | collection = 行情归档的 15m 采集；intrabar = 模拟部署的盘中检查。v4 之前的旧行默认 collection | 4 |