大数据-261 实时数仓-建设指南：从架构设计到业务落地 交易订单、订单产品、产品分类、商家店铺、地域组织表

TL;DR场景企业需要构建实时数据仓库处理流式数据并支持低延迟分析决策结论实时数仓具备低延迟、高并发、高可用等特性通过云原生、湖仓一体、AI集成等方向演进产出完整的实时数仓架构设计思路 7张核心业务数据库表结构解析版本矩阵功能状态说明低延迟数据处理✅ 已验证支持秒级/毫秒级数据处理高并发查询✅ 已验证多用户同时查询高可用架构✅ 已验证数据冗余与容错机制流批一体✅ 已验证实时流计算批量分析云原生部署⚠️ 待验证需结合具体云平台验证湖仓一体⚠️ 待验证结构化与非结构化统一分析AI/ML集成⚠️ 待验证智能分析与预测能力实时数仓的定义实时数仓是一种数据仓库系统区别于传统批处理数仓它强调低延迟、高吞吐和高可用性。实时数仓能够处理流式数据或近实时的数据流使企业能够及时监控关键指标并做出决策。实时数仓的关键特性低延迟数据处理数据从采集到可查询分析的时间极短通常在秒级或毫秒级。高并发查询支持能够支持多用户同时查询满足业务需求。高可用性和可靠性系统在高负载下仍能保持稳定支持数据冗余和容错机制。流批一体既支持实时流式计算也支持批量数据分析满足多样化需求。可扩展性能够通过分布式架构动态扩展存储和计算资源满足不断增长的业务需求。实时数仓的发展趋势云原生实时数仓越来越多企业选择基于云平台搭建实时数仓提升资源管理与成本控制能力。湖仓一体化结合数据湖和数据仓库的优势支持结构化与非结构化数据的统一分析。AI 与机器学习集成实时数仓将与 AI 和机器学习深度结合实现智能分析与预测。开源生态发展更多开源工具不断涌现降低企业建设实时数仓的门槛。业务数据库表结构业务数据库交易订单表trade_orders订单产品表order_product产品信息表product_info产品分类表product_category商家店铺表shops商家地域组织表shop_admin_org支付方式表payments交易订单表CREATETABLEwzk_trade_orders(orderIdbigint(11)NOTNULLDEFAULT0COMMENT订单id,orderNovarchar(20)NOTNULLCOMMENT订单编号,userIdbigint(11)NOTNULLCOMMENT用户id,statustinyint(4)NOTNULLDEFAULT-2COMMENT订单状态 -3:用户拒收 -2:未付款的订单 -1用户取消 0:待发货 1:配送中 2:用户确认收货,productMoneydecimal(11,2)NOTNULLCOMMENT商品金额,totalMoneydecimal(11,2)NOTNULLCOMMENT订单金额包括运费,payMethodtinyint(4)NOTNULLDEFAULT0COMMENT支付方式,0:未知;1:支付宝2微信;3、现金4、其他,isPaytinyint(4)NOTNULLDEFAULT0COMMENT是否支付 0:未支付 1:已支付,areaIdint(11)NOTNULLCOMMENT区域最低一级,tradeSrctinyint(4)NOTNULLDEFAULT0COMMENT订单来源 0:商城 1:微信 2:手机版 3:安卓App 4:苹果App,tradeTypeint(11)DEFAULT0COMMENT订单类型,isRefundtinyint(4)NOTNULLDEFAULT0COMMENT是否退款 0:否 1是,dataFlagtinyint(4)NOTNULLDEFAULT1COMMENT订单有效标志 -1删除 1:有效,createTimevarchar(25)NOTNULLCOMMENT下单时间,payTimevarchar(25)DEFAULTNULLCOMMENT支付时间,modifiedTimetimestampNOTNULLDEFAULTcurrent_timestamp()ONUPDATEcurrent_timestamp()COMMENT订单更新时间)ENGINEInnoDBDEFAULTCHARSETutf8COLLATEutf8_general_ci;备注记录订单的信息status 订单状态createTime、payTime、modifiedTime订单产品表CREATETABLEwzk_order_product(idbigint(11)NOTNULLDEFAULT0,orderIdbigint(11)NOTNULLCOMMENT订单id,productIdbigint(11)NOTNULLCOMMENT商品id,productNumbigint(11)NOTNULLDEFAULT0COMMENT商品数量,productPricedecimal(11,2)NOTNULLDEFAULT0.00COMMENT商品价格,moneydecimal(11,2)DEFAULT0.00COMMENT付款金额,extratextDEFAULTNULLCOMMENT额外信息,createTimevarchar(25)DEFAULTNULLCOMMENT创建时间)ENGINEInnoDBDEFAULTCHARSETutf8COLLATEutf8_general_ci;备注记录订单中购买产品的信息包括产品的数量、单价等产品信息表CREATETABLEwzk_product_info(productIdbigint(11)NOTNULLDEFAULT0COMMENT商品id,productNamevarchar(200)NOTNULLCOMMENT商品名称,shopIdbigint(11)NOTNULLCOMMENT门店ID,pricedecimal(11,2)NOTNULLDEFAULT0.00COMMENT门店价,isSaletinyint(4)NOTNULLDEFAULT1COMMENT是否上架 0:不上架 1:上架,statustinyint(4)NOTNULLDEFAULT0COMMENT是否新品 0:否 1:是,categoryIdint(11)NOTNULLCOMMENTgoodsCatId 最后一级商品分类ID,createTimevarchar(25)NOTNULL,modifyTimedatetimeDEFAULTNULLONUPDATEcurrent_timestamp()COMMENT修改时间)ENGINEInnoDBDEFAULTCHARSETutf8COLLATEutf8_general_ci备注记录产品的详细信息对应商家 ID、商品属性是否新品、是否上架createTime、modifyTime、创建时间、修改时间产品分类表CREATETABLEwzk_product_category(catIdint(11)NOTNULLDEFAULT0COMMENT品类ID,parentIdint(11)NOTNULLCOMMENT父ID,catNamevarchar(20)NOTNULLCOMMENT分类名称,isShowtinyint(4)NOTNULLDEFAULT1COMMENT是否显示 0:隐藏 1:显示,sortNumint(11)NOTNULLDEFAULT0COMMENT排序号,isDeltinyint(4)NOTNULLDEFAULT1COMMENT删除标志 1:有效 -1删除,createTimevarchar(25)NOTNULLCOMMENT建立时间,leveltinyint(4)DEFAULT0COMMENT分类级别共3级)ENGINEInnoDBDEFAULTCHARSETutf8COLLATEutf8_general_ci;备注产品分类表共分3 个级别-- 第一级产品目录selectcatName,catidfromwzk_product_categorywherelevel1;-- 查看电脑、办公的子类查看二级目录selectcatName,catidfromwzk_product_categorywherelevel2andparentId32;-- 查看电脑整机的子类查看三级目录selectcatName,catidfromwzk_product_categorywherelevel3andparentId10250;执行结果如下图所示商家的店铺表CREATETABLEwzk_shops(shopIdint(11)NOTNULLDEFAULT0COMMENT商铺ID自增,userIdint(11)NOTNULLCOMMENT商铺联系人ID,areaIdint(11)DEFAULT0,shopNamevarchar(100)DEFAULTCOMMENT商铺名称,shopLeveltinyint(4)NOTNULLDEFAULT1COMMENT店铺等级,statustinyint(4)NOTNULLDEFAULT1COMMENT商铺状态,createTimedateDEFAULTNULL,modifyTimedatetimeDEFAULTNULLCOMMENT修改时间)ENGINEInnoDBDEFAULTCHARSETutf8COLLATEutf8_general_ci;备注记录店铺的详细信息商家地域组织表CREATETABLEwzk_shop_admin_org(idint(11)NOTNULLDEFAULT0COMMENT组织ID,parentIdint(11)NOTNULLCOMMENT父ID,orgNamevarchar(100)NOTNULLCOMMENT组织名称,orgLeveltinyint(4)NOTNULLDEFAULT1COMMENT组织级别1;总部及大区级部门;2总部下属的各个部门及基部门;3:具体工作部门,isDeletetinyint(4)NOTNULLDEFAULT0COMMENT删除标志,1:删除;0:有效,createTimevarchar(25)DEFAULTNULLCOMMENT创建时间,updateTimevarchar(25)DEFAULTNULLCOMMENT最后修改时间,isShowtinyint(4)NOTNULLDEFAULT1COMMENT是否显示,0:是 1:否,orgTypetinyint(4)NOTNULLDEFAULT1COMMENT组织类型,0:总裁办;1:研发;2:销售;3:运营;4:产品)ENGINEInnoDBDEFAULTCHARSETutf8_general_ci;备注记录店铺所属区域支付方式表CREATETABLEwzk_payments(idint(11)NOTNULL,payMethodvarchar(20)DEFAULTNULL,payNamevarchar(255)DEFAULTNULL,descriptionvarchar(255)DEFAULTNULL,payOrderint(11)DEFAULT0,onlinetinyint(4)DEFAULTNULL)ENGINEInnoDBDEFAULTCHARSETutf8COLLATEutf8_general_ci;备注记录支付方式最终结果整体截图错误速查卡症状根因定位修复订单状态显示异常status字段枚举值理解偏差检查status-3/-2/-1/0/1/2对应的业务含义按文档注释核对枚举定义分类查询结果为空parentId使用错误确认level与parentId的层级关系参考三级分类示例查询支付方式匹配失败payMethod类型不匹配检查支付方式表与订单表关联字段确保payMethod值类型一致订单金额计算错误decimal精度问题检查productMoney与totalMoney字段decimal(11,2)最大99999999.99店铺关联查询无数据areaId跨表关联缺失检查shops表与shop_admin_org表关系通过areaId关联地域组织表