票易通Redshift 数仓治理与挖掘 · 实测汇报
2026-09-07 · 只读实测 · 证据分级 E0–E2 · 内部资料

Redshift 数仓治理与挖掘(redshift-cluster-yl / dev,AWS 宁夏)

依据交接文档、治理挖掘方案与参考工作簿,对生产数仓做只读实测:目录与消费方 → 过程血缘 → 成本感知画像 → 冗余清退 → ontoos 交叉核对。所有数字可在工作簿 29_查询清单 与 evidence/ 复现。

一、结论摘要

总存储(RA3 托管存储)
21.85TB
dev.public · 3 节点 × 2 slice
物理表
5,738
有数据 4,130 · 空壳 1,608
存储过程
1,081
plpgsql · 797 个 sp_psa_
活跃账号 / 账号
20/ 45
7 天连接日志
可清退候选
590.0GB
842 张 · 三重证据
超级用户服务账号
1
biplatform · 4 位点共用
BI 报表账号可写表
5,727
quickbireport · report_group
bi-sync 同步目标表
372
8,170.4 GB · DMS 任务表实查
  1. 家底核实一致:表 5,738(有数据 4,130,空壳 1,608),21.85 TB / 1626.0 亿行;但"薄建模"要修正——建模逻辑在 1,081 个存储过程里(797 个 sp_psa_ 做 CDC 合并),另有 179 个自动物化视图。
  2. 仓的运转方式已还原:Kafka/消息总线 → bi-sync 服务缓存到 S3 → COPY 进 _ty_kafka 中转表 → sp_psa_* 合并进贴源表 → sp_report/sp_m 派生;过程之间没有任何 CALL,调度在外部 DolphinScheduler(Python 任务,峰值 00:00)。
  3. bi-sync 的写入面已闭合:DMS 任务表 392 个任务 → 372 张目标表(8,170.4 GB),与 Redshift 表名 100% 匹配;但 m_finacc_seller_invoice、m_vat_invoice_item_all、ods_kafka_monitor_system 等最大的表既无过程写入也不在同步任务表中,写入方仍待定位。
  4. 消费方从 4 个账号扩展为 20 个活跃 / 45 个账号:自研 Redash、阿里云 QuickBI、OpenMetadata 爬虫(bi-export)、DataGrip/DBeaver 人工查询,以及 4 个用个人账号跑生产的服务。
  5. 账号安全最紧迫:biplatform 是超级用户且被 4 个部署位点 + 调度器 + 办公网共用;quickbireport 经 report_group 拥有 5,727 张表 INSERT/DELETE;个人账号拥有 169 张表 400.7 GB;25 个账号 7 天无连接;凭据写死在镜像里。
  6. BI 热点在进项发票池(购方侧)而不是销项:自动物化视图引用最多的是 …purchaserinvoicemanagesaas_invoicebusiness(22)与 _invoicemain(17),psa_inv_seller_invoice 排第三(10)。
  7. 冗余与清退有据:1,082 个同基名簇 / 3,670 张表;三重证据筛出可清退候选 842 张 590.0 GB,另有 10 张日志类大表 1,747.6 GB 需要保留期策略。
  8. _v1/_v2/_pro 是按来源库实例拆分的并行分片(各含一个 sync_from_db_instance、近 7 天持续摄取),不是旧版本;_0、_3_ali、_bak_ty_kafka、m_vat_invoice_all/_item_all 等 8 张核心表 ≥90 天无摄取,合计 1915.3 GB,其中 3 张仍被读取(历史归档),其余可进入清退观察。
  9. m_finacc_seller_invoice 不是一行一票:近 30 天切片 5,578 万行只对应 854 万个 invoice_id(平均 6.5 行/票);psa_inv_seller_invoice(按 id)与 psa_seller_invoice(按 invoice_id)切片内唯一,销项头→行关联孤儿率 0.00%。
  10. 语义资产比预想多:982 张表注释、41,095 条列注释(24.0%)可直接作为字典 E1 证据;但 psa_inv_seller_invoice(169 列)等核心表 0 注释。
  11. 类型风险:金额类列 33.3% 为字符串,时间类列 42.5% 字符串 / 24.8% bigint,varchar(65535) 列 6,831 个;聚合前必须转换。
  12. ADB-PG 是平行体:阿里云 ADB-PG biplatform.public 2,934 张表中 1,149 张与 Redshift 同名(涉及 9,882.9 GB);bi-sync 与 daas 服务双源配置——迁移/双写状态必须先澄清。

证据分级:E0 待验证 → E1 结构证据(DDL/注释/过程源码/ACL)→ E2 样本/切片验证(范围已注明)→ E3 多期勾稽 → E4 业务签署。本次最高到 E2;所有查询只读、逐条超时、留档 552 条(成功 542)。

二、家底复核(交接 vs 实测)

存储按族群(GB)

psa: 15,491.8 GBpsa15,491.8 GBm: 4,295.0 GBm4,295.0 GBods: 1,255.6 GBods1,255.6 GBtemp/tmp: 639.5 GBtemp/tmp639.5 GBother: 322.1 GBother322.1 GBdwd: 213.8 GBdwd213.8 GBreport: 69.3 GBreport69.3 GBdm: 51.3 GBdm51.3 GBdim: 24.1 GBdim24.1 GBcheck: 10.1 GBcheck10.1 GBdws: 1.9 GBdws1.9 GBbi: 1.7 GBbi1.7 GBt: 1.4 GBt1.4 GBtest: 0.5 GBtest0.5 GB
表格视图:存储按族群
族群表数空壳GB行数 亿
psa3394115815,491.81,027.7
m356364,295.0312.7
ods2821,255.682.4
temp/tmp681107639.5137.2
other331110322.139.8
dwd70213.89.3
report1301569.34.9
dm45051.39.8
dim3051424.11.5
check44516510.10.2
dws101.90.3
bi201.70.1
t711.40.2
test600.50.0

表数:有数据 vs 空壳(按族群)

有数据空壳
psa: 有数据 2,236,空壳 1,158psa3,394temp/tmp: 有数据 574,空壳 107temp/tmp681check: 有数据 280,空壳 165check445m: 有数据 320,空壳 36m356other: 有数据 221,空壳 110other331dim: 有数据 291,空壳 14dim305report: 有数据 115,空壳 15report130dm: 有数据 45,空壳 0dm45ods: 有数据 26,空壳 2ods28dwd: 有数据 7,空壳 0dwd7t: 有数据 6,空壳 1t7test: 有数据 6,空壳 0test6bi: 有数据 2,空壳 0bi2dws: 有数据 1,空壳 0dws1
表格视图:表数
族群有数据空壳
psa22361158
temp/tmp574107
check280165
m32036
other221110
dim29114
report11515
dm450
ods262
dwd70
t61
test60
bi20
dws10

按创建年份的存储(GB)

2023: 12,621 GB12,62120232024: 5,854 GB5,85420242025: 1,897 GB1,89720252026: 2,006 GB2,0062026

2023 年建表 2,291 张 / 12.6 TB,与 gp_sync_type 列(1,128 张表)、varchar 长度 ×3 等 Greenplum 迁移痕迹一致。

表格视图:创建年份
年份表数GB
2023229112620.6
202418805854.4
20259611896.6
20266042006.4

psa 业务域存储(前 12,GB)

inv: 4,033 GBinv4,033 GBathena: 2,036 GBathena2,036 GBseller: 1,800 GBseller1,800 GBeccp: 1,177 GBeccp1,177 GBord: 1,177 GBord1,177 GBtaxware: 766 GBtaxware766 GBinvoice: 490 GBinvoice490 GBtocorder: 487 GBtocorder487 GBpur: 394 GBpur394 GBoqs: 342 GBoqs342 GBtbl: 337 GBtbl337 GBcooperation: 186 GBcooperation186 GB

对交接结论的修正

交接判断实测修正
视图仅 15 个,无分层语义15 个公共视图 + 179 个自动物化视图 + 1,081 个存储过程语义在过程里,不在视图里
max pct_used=0.78% 磁盘健康该值是单表占比;本地盘 5.73 TB 已用 50.5%,数据主体在 RA3 托管存储按用量计费,清退直接省钱
另一库 yl_redshift_db 待登记可连接,无用户表空库,无需登记
yl_test 为 Spectrum 外部 schema外部表 0 张无外部扫描成本
其他用户查询日志不可见证实;但 stl_connection_log / stl_analyze / stl_vacuum / stv_partitions 全量可见用 analyze/vacuum 日志作为 7 天变更代理
stats_off>50% 有 440 张其中 >1 GB 的 60 张(1,045.1 GB)只处理大表
unsorted>50% 有 430 张排序有收益的仅 2 张证实交接的“勿误判”

三、仓的真实运转方式(本次新发现)

源系统 MySQL ×50 库canal-bi-* ×20 → KafkaKafka / SQS / 消息总线tower-invoices · 4 通道bi-sync-redshift-service3+2 Pod · 缓存→S3→COPY_ty_kafka 中转表CDC 事件 _op / _timestampsp_psa_* ×797去重 → 删旧 → 插入 → 留痕psa_ 贴源 3,394 表15.5 TB · 371 张为同步目标DolphinScheduler 3.1.8(bi-prod)Python 任务逐个 CALL · 每日 ~636 会话sp_report / sp_m / sp_check→ m_ / report_ / check_ 表BI 消费Redash · QuickBI · 自动MV ×179ADB-PG biplatform(平行体)1,149 张同名表 · 双源配置实线框=本次实测确认;橙框=外部驱动/平行体(ontoos 湖仓交叉核对);bi-sync 目标表清单来自 DMS 纳管的任务表(392 任务 → 372 目标表,100% 与 Redshift 表名匹配)。

过程层

  • 1,081 个 plpgsql 过程全部归 biplatform:sp_psa 797、sp_check 110、sp_report 88、sp_dreport 14、sp_oqs 9、sp_dim 8、sp_m 8、sp_nippon 5(立邦客户专属,最大单个 422 KB)。
  • 典型 sp_psa_<表>_ty_kafka:按中转表 _op/_timestamp 去重 → 删除旧行 → 插入 → 删除事件写入 _op_delete。
  • 解析出 5,921 条已知表引用、463 条过程内临时表、509 条未知对象;CALL 图为空。

外部驱动

  • Python 会话(application_name=__main__)来自 Pod 172.18.203.24/25 与 192.168.90.217,每日约 636 次,峰值 00:00 CST。
  • ontoos 湖仓确认 bi-prod 部署 DolphinScheduler 3.1.8(master 2 / worker 5)。

服务写入(线程名证据)

  • KakfaMqLogHandler_saveCacheToS3 → KakfaMqLogHandler_pullS3ToRedshift;TaxwareInvoiceDkToRedShiftService / CommonDataSaveToRedShiftService / StatisticsLogService。
  • 输入:AWS SQS prod-consistence-invoice + 消息总线四通道 + Kafka(canal-bi-* ×20 投递 tower-invoices)。
  • 目标表:DMS 任务表 392 任务 → 372 张(type 3 实时 360 / type 2 每日 24 / type 1 8),381 个任务在 2026-09-07 有成功同步。

语义与平行体

  • 982 张表注释 / 41,095 条列注释(psa 25.6%、m 18.7%)。
  • ADB-PG biplatform.public 2,934 张表,与 Redshift 同名 1,149 张;bi-sync 与 daas 双源配置 → 平行体/迁移目标(推断,需 BI 团队确认)。

四、消费方地图

窗口 2026-08-31 00:00 → 09-07 10:43 UTC,417,058 条连接事件;rdsdb(AWS 内部 44,970 会话)未画入。

7 天会话数(前 14 账号)

biplatform: 31,533 会话 / 21 主机 / 192.168.90(专线/IDC?);办公网(172.25);阿里云K8s Pod(172.18) / bi-sync 同步服务线程(7963);Java 连接池(Hikari)(5428);Python 脚本(__mainbiplatform31,533—bi_datavalue_user: 18,093 会话 / 5 主机 / 阿里云K8s Pod(172.18) / Java 连接池(Hikari)(18093)bi_datavalue_user18,093—bi_user_redash: 10,855 会话 / 3 主机 / 阿里云K8s Pod(172.18) / Redash 连接池(10847);xxl-job 调度线程(8)bi_user_redash10,855—gongjianfeng: 3,258 会话 / 1 主机 / 阿里云K8s Pod(172.18) / gongjianfeng3,258—bi_user_gulei: 2,105 会话 / 2 主机 / 办公网(172.25) / Java 连接池(Hikari)(1437);Python 脚本(__main__)(667);DataGrip/Jetbi_user_gulei2,105—quickbireport: 581 会话 / 1 主机 / AWS同VPC(172.31) / QuickBI 引擎(581)quickbireport581—metadata_user: 394 会话 / 10 主机 / 阿里云K8s Pod(172.18) / Java 连接池(Hikari)(366)metadata_user394—fanguozhu: 30 会话 / 1 主机 / 办公网(172.25) / 本次治理分析工具(30)fanguozhu30—wangruiqi: 28 会话 / 1 主机 / 办公网(172.25) / wangruiqi28—tianyang: 14 会话 / 1 主机 / 阿里云K8s Pod(172.18) / 推送服务线程(14)tianyang14—ou_robot: 11 会话 / 1 主机 / 办公网(172.25) / ou_robot11—bi_user_ted: 8 会话 / 3 主机 / 阿里云K8s Pod(172.18) / bi_user_ted8—sunquanfeng: 8 会话 / 2 主机 / 办公网(172.25) / DataGrip/JetBrains 交互(8)sunquanfeng8—bi_operations: 7 会话 / 1 主机 / AWS同VPC(172.31) / bi_operations7—

BI 热表(自动物化视图引用数)

psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoicebusiness: 自动MV引用 22 · 41.6 GB · 发票业务对象psa_pur_invoice_p…esaas_invoicebusiness22—psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoicemain: 自动MV引用 17 · 59.6 GB · 发票票面信息对象psa_pur_invoice_p…anagesaas_invoicemain17—psa_inv_seller_invoice: 自动MV引用 10 · 246.4 GB · psa_inv_seller_invoice10—dm_egg_sunart_base_prepare1: 自动MV引用 8 · 0.3 GB · dm_egg_sunart_base_prepare18—dim_invoice_type_new: 自动MV引用 8 · 0.0 GB · dim_invoice_type_new8—m_f_data_same_model: 自动MV引用 7 · 0.9 GB · m_f_data_same_model7—psa_cms_dim_date: 自动MV引用 7 · 0.3 GB · psa_cms_dim_date7—m_walmart_seller_invoice: 自动MV引用 6 · 82.7 GB · 沃尔玛销项发票模型m_walmart_seller_invoice6—psa_inv_seller_invoice_v2: 自动MV引用 5 · 64.5 GB · 销项发票主表psa_inv_seller_invoice_v25—psa_purchaser_verify_detail: 自动MV引用 5 · 32.8 GB · psa_purchaser_verify_detail5—m_f_data_same_compare_model_tmp: 自动MV引用 4 · 1.0 GB · m_f_data_same_compare_model_tmp4—m_f_company: 自动MV引用 4 · 0.9 GB · m_f_company4—
阿里云 K8s Pod 172.18.x
59,874
7 账号 / 34 主机
办公网 172.25.x
2,252
11 账号 / 18 主机 · DataGrip/DBeaver
AWS 同 VPC 172.31.x
588
QuickBI + bi_operations 03:00
192.168.90.217
4,230
biplatform Python 任务
账号会话主机网段客户端签名可读表可写表拥有表性质已知部署/用途
biplatform31,53321192.168.90(专线/IDC?);办公网(172.25);阿里云K8s Pod(172.18)bi-sync 同步服务线程(7963);Java 连接池(Hikari)(5428);Python 脚本(__main5,7535,7535,570服务账号bi-sync-redshift-service / sync-redshift-from-other-channel
bi_datavalue_user18,0935阿里云K8s Pod(172.18)Java 连接池(Hikari)(18093)3144服务账号daas-standard-invoice(daas-ks-prod,清单 #5,Hikari 池 5 副本)
bi_user_redash10,8553阿里云K8s Pod(172.18)Redash 连接池(10847);xxl-job 调度线程(8)31200服务账号Redash BI(清单未登记)+ xxl-job 调度
gongjianfeng3,2581阿里云K8s Pod(172.18)1000个人账号invoice-title-dataclean2(janus-prod,清单 #6,个人账号跑生产)
bi_user_gulei2,1052办公网(172.25)Java 连接池(Hikari)(1437);Python 脚本(__main__)(667);DataGrip/Jet5,73000BI命名账号办公网 172.25.17.100 上的 Java 服务(Hikari)+Python 脚本(个人命名账号长期驻留)
quickbireport5811AWS同VPC(172.31)QuickBI 引擎(581)5,7495,7270服务账号阿里云 QuickBI(清单未登记,AWS 同 VPC 172.31.156.63)
metadata_user39410阿里云K8s Pod(172.18)Java 连接池(Hikari)(366)5,73020服务账号元数据爬虫(RedshiftHikariPool,每日 07:00 UTC)
fanguozhu301办公网(172.25)本次治理分析工具(30)5,65600个人账号本机 DBeaver / 本次治理分析(清单 #7)
wangruiqi281办公网(172.25)5,73000个人账号
tianyang141阿里云K8s Pod(172.18)推送服务线程(14)1709795个人账号K8s Pod 推送服务(push-async,每日 20:00 UTC;个人账号跑生产,拥有 95 张表)
ou_robot111办公网(172.25)5,73000服务账号
bi_user_ted83阿里云K8s Pod(172.18)1,8126438BI命名账号K8s Pod 定时任务(每日 01:38 UTC)
sunquanfeng82办公网(172.25)DataGrip/JetBrains 交互(8)5,73000个人账号
bi_operations71AWS同VPC(172.31)400服务账号AWS 同 VPC 定时任务(每日 19:00 UTC,与 QuickBI 同主机)
guiweidong61办公网(172.25)JDBC 客户端交互(DBeaver等)(6)5,73000个人账号
lvwenjing62办公网(172.25)DataGrip/JetBrains 交互(6)5,73000个人账号
wangchen31办公网(172.25)JDBC 客户端交互(DBeaver等)(3)5,75300个人账号
cailibin21办公网(172.25)JDBC 客户端交互(DBeaver等)(2)5,73000个人账号
yuanxuebo21办公网(172.25)DataGrip/JetBrains 交互(2)5,73000个人账号

账号安全发现

E012 biplatform 超级用户E013 quickbireport 可写 5,727 表E014 个人账号跑生产 ×425 个休眠账号凭据随镜像分发Redshift 未纳管 DMS

  • biplatform:超级用户;4 个部署位点(含 SIT)+ DolphinScheduler + 办公网 DataGrip 共用,拥有 5,570 张表。
  • quickbireport:经 report_group 拥有 5,727 张表 INSERT/DELETE;bi_user_xialin 可写 1,724 张。
  • gongjianfeng(janus-prod,3,258 会话)、tianyang(推送服务,每日 04:00,拥有 95 张表 376 GB)、bi_user_gulei(办公网常驻 Java+Python 服务)、bi_user_ted(K8s 定时任务)用个人账号跑生产。
  • Redshift 连接串写死在镜像 application-*.yml,不经 Apollo/Secret(ontoos 实查)。

五、血缘与引用覆盖

被过程/视图/自动MV引用
2,812
张表
未被引用
2,926
9,531.8 GB
未引用但 7 天内有变更
592
7,086.1 GB · 写入方待定位
7 天内有变更证据
1,436
18.35 TB

未被过程/同步任务引用的最大表(多为服务直写,不是废弃)

GB行数 亿7 天变更清退分层
m_finacc_seller_invoice732.826.6
m_vat_invoice_item_all533.863.1
ods_kafka_monitor_system470.336.3T5 日志/监控类大表·建议保留期策略
psa_seller_invoice452.28.1
ods_log_message_open_api_v1401.211.7T5 日志/监控类大表·建议保留期策略
m_walmart_seller_invoice_item394.325.6
psa_inv_seller_invoice_item_0330.225.9T4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验
psa_inv_seller_pre_invoice_item302.523.8
psa_ord_salesbill_bak_ty_kafka259.46.8T3b 备份/历史·仍被引用/变更中·核验
psa_inv_seller_pre_invoice_item_0240.720.5T4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验
psa_tbl_task_detail229.54.1
psa_ord_salesbill_item_bak_ty_kafka227.413.0T3b 备份/历史·仍被引用/变更中·核验

交接提出的“8 天无访问即无依赖”不成立:调度在仓外,最大的表由过程外写入。本次血缘覆盖 = 过程 + 视图 + 自动MV + bi-sync 任务表 + ACL 授权面 + 应用名签名;仍缺 Redash/QuickBI 报表 SQL 与 DolphinScheduler 任务定义。

六、核心表画像(C2:成本感知画像)

无谓词的 APPROXIMATE COUNT(DISTINCT) 在 26.5 亿行表 150 秒超时;改为前 N 行样本 + 摄取时间列谓词收敛(zone map 剪枝,0.5–4 秒)+ 近 30 天切片内粒度 + ≤3.5 亿行表全表近似。范围写在表头。

规模、新鲜度与粒度

COUNT(*)摄取时间列近 7 天行近 30 天行(=切片)最大摄取时间切片去重键切片重复率切片租户数切片实例数
m_vat_invoice_item_all6,304,926,542delta_time000
psa_seller_invoice_item5,346,654,477delta_time19,320,30751,760,2642026-09-07 03:36:1551,760,2640.00%
psa_eccp_tocorder_oqs_tocorder_orderitembwcj4,622,191,607delta_time32,251,393137,383,5212026-09-07 16:28:24137,383,5210.00%11
ods_kafka_monitor_system3,631,852,900create_time17,661,87369,612,2492026-09-07 19:20:12
psa_inv_seller_invoice_item3,016,086,226delta_time14,605,69454,446,9262026-09-07 03:15:4954,446,9240.00%
psa_taxware_invoice_collection_item2,942,877,716delta_time002026-08-07 19:52:16000
m_finacc_seller_invoice2,654,674,753delta_time10,036,07055,776,0262026-09-07 03:48:598,538,61584.69%
psa_inv_seller_invoice_item_02,574,781,788delta_time000
psa_seller_invoice_item_pro2,533,084,056delta_time13,507,86841,632,3392026-09-07 13:46:0441,632,3390.00%1
m_walmart_seller_invoice_item2,525,080,753delta_time22,165,11099,236,0832026-09-06 21:44:538,018,45391.92%
psa_inv_seller_pre_invoice_item2,376,884,475delta_time12,746,85442,389,3562026-09-07 03:13:0442,389,3550.00%
psa_inv_seller_business_delivery_log2,313,686,764delta_time21,090,25785,621,6822026-09-07 01:06:4085,621,6820.00%1
psa_ord_salesbill_item2,207,909,029delta_time15,747,12543,518,8642026-09-07 18:51:4843,518,8640.00%1
psa_athena_tencent_t_settlement_item1,997,447,084delta_time11,499,25634,604,9632026-09-07 00:46:2534,604,9630.00%1
psa_inv_seller_invoice_item_v11,668,780,959delta_time6,408,48924,158,1442026-09-07 18:27:1524,158,1440.00%1
psa_inv_seller_invoice_item_v21,321,470,014delta_time10,282,57832,340,9132026-09-07 18:29:4332,340,9130.00%1
psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoiceitem1,178,090,178delta_time19,130,634235,464,6862026-09-07 02:05:47235,464,6860.00%6083
ods_log_message_open_api_v11,171,773,379
m_vat_invoice_all1,138,313,846delta_time000
m_inv_hdr_2c_ope_dtl1,026,032,705
m_datavalue_inout_invoice1,017,990,959delta_time000
psa_seller_invoice794,707,929delta_time2,369,2306,690,4312026-09-07 03:33:596,690,4310.00%
psa_ord_salesbill_bak_ty_kafka679,907,393update_time0000
psa_inv_seller_invoice558,819,631delta_time3,297,98012,488,2842026-09-07 03:25:4812,488,2810.00%
psa_tocorder_oqs_tocorder_ordereleme545,096,160delta_time10,527,19347,765,5012026-09-07 02:29:2847,765,5010.00%31
m_full_seller_invoice_delete533,814,282delta_time000
psa_taxware_invoice_collection_main531,367,975delta_time002026-08-07 19:52:16000
psa_ord_salesbill503,501,495delta_time6,685,61014,665,9602026-09-07 18:51:5714,665,9600.00%1
psa_inv_seller_invoice_v1414,873,158delta_time2,333,0338,195,2032026-09-07 18:59:478,195,2030.00%1
psa_tbl_task_detail393,490,053delta_time1,544,0025,126,5742026-09-07 00:51:595,126,5740.00%
m_walmart_seller_invoice379,341,516delta_time2,768,9508,535,6442026-09-07 03:50:428,535,6440.00%
psa_seller_invoice_pro345,105,300delta_time1,564,0985,766,8842026-09-07 15:02:135,766,8840.00%1
psa_seller_invoice_3_ali271,065,089delta_time0000
psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoicemain240,776,735delta_time4,258,50911,619,0142026-09-07 01:43:4511,619,0140.00%6283
psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoicebusiness240,688,726delta_time4,084,41311,684,8132026-09-07 02:42:2811,684,8130.00%6283
psa_invoice_seller_main198,511,758delta_time000
psa_inv_seller_invoice_v2141,283,889delta_time1,395,9394,696,4072026-09-07 19:07:254,696,4070.00%1
psa_pim_invoice_main85,274,518delta_time11,92445,3352026-09-07 01:43:1945,3350.00%1
psa_bss_company_new208,848delta_time1,0413,4082026-09-07 17:45:393,4080.00%1
psa_bss_tenant_new108,492delta_time2118672026-09-07 01:04:418670.00%8671

近 7 天无摄取的核心表:m_vat_invoice_item_all、psa_taxware_invoice_collection_item、psa_inv_seller_invoice_item_0、m_vat_invoice_all、m_datavalue_inout_invoice、psa_ord_salesbill_bak_ty_kafka、m_full_seller_invoice_delete、psa_taxware_invoice_collection_main、psa_seller_invoice_3_ali、psa_invoice_seller_main

核心表中的停更表(≥90 天无摄取或最后摄取 >30 天)

GB行数摄取时间列最后摄取读取过程数自动MV引用清退分层
psa_inv_seller_invoice_item_0330.22,574,781,788delta_time≥90 天无00T4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验
m_vat_invoice_all154.51,138,313,846delta_time≥90 天无00T4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验
m_vat_invoice_item_all533.86,304,926,542delta_time≥90 天无00
psa_taxware_invoice_collection_main78.0531,367,975delta_time2026-08-07 19:52:1620
psa_taxware_invoice_collection_item292.12,942,877,716delta_time2026-08-07 19:52:1620
psa_seller_invoice_3_ali171.6271,065,089delta_time≥90 天无83T4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验
psa_ord_salesbill_bak_ty_kafka259.4679,907,393update_time≥90 天无00T3b 备份/历史·仍被引用/变更中·核验
m_full_seller_invoice_delete206.2533,814,282delta_time≥90 天无02
m_datavalue_inout_invoice134.81,017,990,959delta_time≥90 天无21
psa_invoice_seller_main124.7198,511,758delta_time≥90 天无01

psa_taxware_invoice_collection_main/item(税件归集,379 GB)最后摄取 2026-08-07,采集链路已中断一个月,需确认是停用还是故障。销项头→行两条关系孤儿率 0.00%;单据头→行 0.16% 孤儿行需区分父表时间截断与真实缺失;psa_seller_invoice_item(53 亿行)关联检查 150 秒超时;进项池头行关联未执行:明细表经 OQS 关系字段 invoiceitemandinvoicemainrelation_id 指向 invoicemain.id,需按该列另测。

主从关联(子表近 30 天摄取切片 → 父表)

关系子表切片行父键数孤儿行孤儿率孤儿键
psa_inv_seller_invoice_item → psa_inv_seller_invoice54,446,93411,318,32210.00%1
…_item_v1 → …_invoice_v124,158,1447,398,07480.00%2
psa_ord_salesbill_item → psa_ord_salesbill43,518,86412,486,62571,6070.16%5,689
psa_seller_invoice_item → psa_seller_invoice超时/未执行
进项 invoiceitem → invoicemain未执行

_v1/_v2/_0/_pro 是版本还是分片(sync_from_db_instance)

范围实例分布
psa_inv_seller_invoice无该列/未测
psa_inv_seller_invoice_v1近30天切片1226563967195942917=8,195,203
psa_inv_seller_invoice_v2全表1226563967191748631=141,283,889
psa_inv_seller_invoice_item无该列/未测
psa_inv_seller_invoice_item_v1近30天切片1226563967195942917=24,158,144
psa_inv_seller_invoice_item_v2近30天切片1226563967191748631=32,340,913
psa_inv_seller_invoice_item_0无该列/未测
psa_seller_invoice无该列/未测
psa_seller_invoice_pro近30天切片1226563967191748611=5,766,884
psa_seller_invoice_3_ali前20万行样本1795014301224296448=200,000

状态/类型枚举样本(前 20 万行)

取值=计数
m_finacc_seller_invoicestatus1=191,805, 0=7,206, 5=989
m_finacc_seller_invoiceinvoice_types=76,891, c=66,647, ce=51,887, ct=1,743, j=1,503, ju=1,044, se=195
psa_inv_seller_invoicestatus1=197,852, 9=1,438, 0=708, 2=2
psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoicemaininvoice_color1=197,000, 2=3,000
psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoicemaininvoice_status1=189,333, 2=6,390, 5=2,599, 3=1,646, 4=18, 6=14
psa_ord_salesbillstatus1=191,436, 0=8,564
m_vat_invoice_allinvoice_types=181,752, c=15,254, ct=1,859, (空)=423, --=416, ce=224, ju=58

七、冗余与清退

同基名簇
1,082
3,670 张表
结构克隆非规范成员
4,403.3GB
Jaccard ≥ 0.9
可清退候选
590.0GB
842 张
日志/监控类大表
1,747.6GB
10 张 · 保留期策略

清退分层存储(GB)

T2a 临时前缀·无引用无变更·可清退候选: 278 张 / 294.9 GBT2a 临时前缀·无引用无变更·可清退候选295 GBT2b 临时前缀·仍被引用/变更中·核验: 296 张 / 344.6 GBT2b 临时前缀·仍被引用/变更中·核验345 GBT3a 备份/历史·无引用无变更·可清退候选: 15 张 / 56.2 GBT3a 备份/历史·无引用无变更·可清退候选56 GBT3b 备份/历史·仍被引用/变更中·核验: 94 张 / 1,082.9 GBT3b 备份/历史·仍被引用/变更中·核验1,083 GBT4a 结构克隆·无引用无变更·可清退候选: 138 张 / 238.9 GBT4a 结构克隆·无引用无变更·可清退候选239 GBT4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验: 680 张 / 3,510.6 GBT4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验3,511 GBT5 日志/监控类大表·建议保留期策略: 10 张 / 1,747.6 GBT5 日志/监控类大表·建议保留期策略1,748 GBT7 测试命名·核验: 31 张 / 19.3 GBT7 测试命名·核验19 GB
表格视图:清退分层
分层表数GB行数 亿
T1a 空壳·无引用·可清退候选4110.00.00
T1b 空壳·有过程/视图依赖或专属授权·保留核验11970.00.00
T2a 临时前缀·无引用无变更·可清退候选278294.974.03
T2b 临时前缀·仍被引用/变更中·核验296344.663.16
T3a 备份/历史·无引用无变更·可清退候选1556.25.93
T3b 备份/历史·仍被引用/变更中·核验941,082.9100.11
T4a 结构克隆·无引用无变更·可清退候选138238.915.29
T4b 结构克隆·仍被引用/变更中(疑似分片或并行版本)·核验6803,510.6245.30
T5 日志/监控类大表·建议保留期策略101,747.6111.06
T7 测试命名·核验3119.34.69

可清退候选 Top 12

GB行数创建
tmp_wqs_scb_xiaoxiang_20231214T2a49.2588,270,8312023-12-15
temp_m_datavalue_inout_invoice_flag2T2a36.1560,186,7522024-01-15
temp_m_datavalue_inout_invoice_flagT2a34.0560,186,7522024-01-15
m_walmart_seller_invoice_tempT4a31.9134,884,6852023-10-08
psa_toi_t_invoice_dkT4a29.683,975,5112025-05-20
psa_taxware_invoice_collection_item_bkT3a23.8321,957,9202024-08-23
tmp_m_s_inv_titleT2a19.3168,161,2212023-11-27
m_purchaser_vat_invoice_allT4a19.0208,292,2902024-07-24
psa_toi_t_ae_invoice_dkT4a18.787,813,4042025-05-21
m_purchaser_vat_invoice_all_temp1T4a17.5208,292,2902024-07-29
tmp_wqs_scb_jinxiang_20231214T2a15.3171,783,0252023-12-15
ods_log_message_taxware_item_bkT3a14.4151,150,6772024-05-29

最大的非规范簇成员

基名变体表GBJaccard7 天变更创建
ods_log_message_open_apiods_log_message_open_api_v1401.20.02024-01-01
psa_inv_seller_invoice_itempsa_inv_seller_invoice_item_0330.21.02023-09-25
psa_seller_invoice_itempsa_seller_invoice_item_pro324.30.9092023-08-06
psa_ord_salesbillpsa_ord_salesbill_bak_ty_kafka259.40.952024-08-08
psa_inv_seller_invoice_itempsa_inv_seller_invoice_item_v1249.50.9342026-03-22
psa_inv_seller_pre_invoice_itempsa_inv_seller_pre_invoice_item_0240.71.02023-09-26
psa_ord_salesbill_itempsa_ord_salesbill_item_bak_ty_kafka227.40.9042024-08-06
psa_athena_tencent_t_settlement_preinvoice_detailpsa_athena_tencent_t_settlement_preinvoice_detail_t1199.71.02023-08-25
psa_inv_seller_invoicepsa_inv_seller_invoice_v1191.60.8842024-03-13
psa_inv_seller_invoice_itempsa_inv_seller_invoice_item_v2186.30.9342026-03-22

日志/监控类大表

GB行数创建7 天变更
ods_kafka_monitor_system470.33,631,840,6352024-01-19
ods_log_message_open_api_v1401.21,172,967,3922024-01-01
psa_inv_seller_business_delivery_log381.32,325,218,2342023-08-27
psa_taxware_invoice_log244.4789,503,5092024-12-26
psa_taxware_invoice_log_bk84.4276,721,6042023-10-07
ods_sqs_monitor_system42.7593,649,6932024-02-20
ods_log_message_taxware_item38.7613,496,9092024-09-12
psa_inv_seller_business_log37.7813,979,8022023-09-26
psa_inv_seller_business_log_v126.9587,216,3842023-08-29
psa_inv_seller_split_request_log20.0301,111,8902023-08-27

规则:T1 空壳;T2 temp/tmp 前缀;T3 bak/old/his;T4 结构克隆;T5 日志类;T7 测试命名。“可清退候选” = 无过程/视图/自动MV/同步任务引用 + 7 天无变更 + 无专属授权。执行:确认 DolphinScheduler 任务定义无引用 → 重命名观察 30 天 → 审批 → DROP 并保留回滚脚本;_ty_kafka 中转表即使空壳也不能删。

八、物理健康与类型风险

统计失效大表
60
1,045.1 GB · stats_off>50% 且 >1GB
排序有收益
2
unsorted>50% 且 benefit>0
金额列为字符串
33.3%
全库 18,516 个金额类列
时间列非时间类型
67.3%
字符串 42.5% + bigint 24.8%
varchar(65535) 列
6,831
4.0% · 按声明长度分配内存
GBstats_off%unsorted%skew_rows
psa_seller_invoice_item562.158.0753.74
psa_taxware_invoice_collection_main78.097.93100.0
m_inv_hdr_2c_ope_dtl64.8100.0
psa_inv_seller_invoice_v264.554.38100.0
psa_pur_invoice_pool_oqs_purchaserinvoicemanagesaas_invoicemain59.6100.095.09
m_f_billing_basis22.1100.0
m_f_account_with_detail12.0100.0
m_f_yunzi_bill11.6100.0
psa_bill_shard_ord_salesbill11.282.017.0
s_full_activetax11.1100.083.42

WLM 自动模式,QMR 仅 1 条(cpu_skew>1 降优先级),无超时/扫描量规则;本次大表聚合是被自身 statement_timeout 取消的。个人账号拥有的表:tianyang 95 张 376.1 GB;bi_user_ted 38 张 17.6 GB;bi_user_xialin 21 张 6.2 GB;bi_user_tableau 10 张 0.3 GB;bi_test 5 张 0.5 GB。

九、业务域覆盖与客户专属数据

业务域(关键词)表数GB有数据
收付款/银行/现金3714.124
应收/应付/账龄10415.685
库存/仓储/出入库1560.612
订单/单据10213565.2636
进项发票(购方)3321212.8253
销项发票(销方)6808400.2504
结算961369.167
商品/品类13136.179
客户/企业主数据51081.2368
合同506.835
物流/交付43403.321
税务申报370549.9250
客户/项目(表名关键词)表数GB
腾讯 tencent1061998.4
霸王茶姬 bawang/bwcj77933.8
沃尔玛 walmart61625.5
饿了么 eleme10496.3
蚂蚁 ant13576.8
屈臣氏 watsons10760.9
立邦 libang/nippon10158.1
万科 wanke/vanke4325.0
云字 yunzi1024.6
联合利华 ul236.1

按表名关键词识别,需业务确认;跨客户使用须授权审查。

销项/进项发票、单据、结算、税件归集齐备;应收/收付款/核销、库存、履约几乎缺失——财务与供应链预测类模型在现仓不可行;经营结构、客户集中度、交易沉默、供应方集中度、采购议价线索、异常票据线索的数据基础具备。

十、指标与模型可行性(基于实测结构)

指标/模型数据可得性(实测)判定
M001 发票口径净开票额psa_inv_seller_invoice(amount_without_tax, status, invoice_type, seller_tax_no, paper_draw_date);m_finacc_seller_invoice 三金额 numeric(18,6)可建,先认证粒度与红字规则
M002 客户 Top5 集中度purchaser_tax_no / purchaser_name 在 715 / 745 张表可建
M003 供应商 HHI进项发票池 invoicemain/invoiceitem(BI 最热对象),amount numeric(20,2),invoice_color可建,数据基础最好
M004 交易沉默天数paper_draw_date + delta_time 可见时间可建
M005 采购单价偏离进项明细含数量/单价/商品列;无标准商品主数据需商品映射
M006 红冲强度invoice_color(购方池);销项红字标识待认证部分
M007 逾期应收仓内无应收/收款/核销表不可计算
M008 数据覆盖门禁租户表、delta_time、sync_from_db_instance可建
O01–O06 / O13 经营、供应链线索、异常票据销项+进项+单据齐备P0 试点候选
O07/O08/O10/O11/O12/O15 履约、库存、应收、现金流、盈利、违约仓内无对应事实需外部数据

十一、治理建议与路线

30 天:速赢(不改数据)

  • 收回 biplatform superuser;拆分调度/服务/人工账号;report_group 收敛为 SELECT;迁移 4 个个人账号跑的生产任务;禁用 25 个休眠账号。
  • DBA 配置 QMR 超时/扫描量规则;对 60 张大表 ANALYZE。
  • 可清退候选 842 张 590.0 GB 进入重命名观察期;为 10 张日志表定义保留期。
  • 与 BI 团队确认 ADB-PG 迁移/双写状态。

60 天:语义还原

  • 导入 41,095 条列注释到字典(E1),补齐核心表注释。
  • 取得 DolphinScheduler 任务定义 + Redash/QuickBI 报表 SQL,闭合端到端血缘。
  • 维护窗口做核心表全表去重计数与头行金额勾稽,认证发票主题粒度。
  • 解决 _v1/_v2/_0 命名(按实例/客户显式命名)。

90 天:资产与试点

  • 规范层统一 numeric/timestamp;建立主体—发票—交易对手—商品认证模型。
  • 首批指标 M001–M004/M008 认证发布。
  • 试点经营结构、供应方集中度、异常票据线索三类客户产品。

十二、方法、边界与产物

只读护栏scripts/rs_run.py:仅 SELECT/WITH/SHOW;关键字黑名单(INTO/CREATE/UNLOAD/COPY…);只读会话;单语句;逐条 statement_timeout;凭据内存解密不落盘。 批次A 目录与消费方(37)、B 过程全文与变更代理(19)、C0 成本校准(5)、C2 核心表画像、D 调度器与第二库;合计 552 条(成功 542,超时/错误 10)。 交叉核对ontoos 研发本体湖仓(服务代码表引用、K8s 工作负载、DMS 纳管库)+ DMS 只读取回 bi-sync 任务表。 权限盲区他人查询日志不可见;97 个对象不可读;DolphinScheduler/Redash/QuickBI 侧定义未取得;ADB-PG 迁移判定为推断。 口径目录行数含未回收删除行;“7 天变更”来自 analyze/vacuum 日志代理;样本与切片结果只代表其范围;业务域/客户按表名关键词识别。 产物报告 Redshift_数仓治理与挖掘报告_20260907.md · 工作簿 Redshift_数仓治理与挖掘工作簿_20260907.xlsx(34 张表)· 本页 https://xforce-dw-governance-cc-0907.pages.dev/ · evidence/(552 条查询留档 + ontoos 交叉核对)· scripts/(可复现)
生成 2026-09-07 19:40 · 采集身份 fanguozhu · 仅供内部治理使用 · 页面不含任何口令与凭据