uid 字段配置空值率规则,试运行、发布、关联告警。create catalog 权限(如无该权限,请联系工作空间管理员或元数据湖 admin 授予)。analyst_alice、ops_bob)用于验证脱敏与行级权限效果。DataLakeCatalog)。本教程的目标是 新建一个面向电商业务域的治理用 Catalog ,与默认 Catalog 解耦,便于演示治理流程。orders_raw:字段 | 类型 | 说明 | 敏感性 |
order_id | BIGINT | 订单号 | 业务关键字段 |
customer_id | BIGINT | 客户 ID | - |
phone | STRING | 客户手机号 | 敏感(PII) |
product_name | STRING | 商品名 | - |
quantity | INT | 数量 | - |
unit_price | DECIMAL(10,2) | 单价 | - |
region | STRING | 销售大区:North / South / East / West | 行级权限维度 |
order_status | STRING | 订单状态:paid / shipped / completed / cancelled | - |
order_time | TIMESTAMP | 下单时间 | - |
uid | STRING | 业务主键(关联用户中心) | 质量规则监控字段 |
<your_name> 替换成您自己的姓名前缀,例如 alice_ecommerce、alice_ods_raw 等。类型 | 容纳的对象 |
Catalog | 表(Table)、视图(View)、函数(Function) |
Volume | 卷(Volume)—— 图片、PDF、CSV 等非结构化文件 |
Model | 模型(Model)—— ML 模型注册与版本管理 |
<your_name>_ecommerce(例如 alice_ecommerce)。电商订单业务域的结构化数据治理目录。default(通用 Schema)。您本人作为创建者自动成为 Catalog 的 Owner ,拥有该 Catalog 下的全部管理权限。<your_name>_ecommerce_files)与 模型文件目录 (如 <your_name>_ml_models)。三类 Catalog 的对象边界详见非结构化数据 Catalog 与 模型 Catalog 。Schema 名称 | 描述 |
ods_raw | 上游业务系统原始入湖数据 |
dwd_detail | 清洗加工后的事实明细表 |
dws_summary | 按维度聚合的指标汇总表 |
governance_setup.sql。⌘ + Enter(Windows 用户 Ctrl + Enter)执行(务必把 your_name 替换为您自己的姓名前缀):-- 1. ODS 层订单原始表CREATE TABLE IF NOT EXISTS your_name_ecommerce.ods_raw.orders_raw (order_id BIGINT COMMENT '订单号',customer_id BIGINT COMMENT '客户 ID',phone STRING COMMENT '客户手机号(敏感字段)',product_name STRING COMMENT '商品名',quantity INT COMMENT '数量',unit_price DECIMAL(10,2) COMMENT '单价',region STRING COMMENT '销售大区',order_status STRING COMMENT '订单状态',order_time TIMESTAMP COMMENT '下单时间',uid STRING COMMENT '业务主键(关联用户中心)') COMMENT '电商订单原始入湖表';
-- 2. 灌入演示数据(特意留 1 行 uid 为 NULL,用于触发后续质量规则)INSERT INTO your_name_ecommerce.ods_raw.orders_raw VALUES(1001, 501, '13800138000', 'Wireless Mouse', 2, 79.00, 'North', 'completed', TIMESTAMP '2025-01-15 10:30:00', 'u_001'),(1002, 502, '13900139000', 'Mechanical Keyboard', 1, 399.00, 'South', 'completed', TIMESTAMP '2025-01-15 11:15:00', 'u_002'),(1003, 503, '13700137000', 'USB-C Hub', 3, 128.00, 'East', 'paid', TIMESTAMP '2025-01-15 14:20:00', 'u_003'),(1004, 501, '13800138000', 'Monitor Stand', 1, 259.00, 'North', 'completed', TIMESTAMP '2025-01-16 09:00:00', 'u_001'),(1005, 504, '13600136000', 'Wireless Mouse', 1, 79.00, 'West', 'shipped', TIMESTAMP '2025-01-16 16:45:00', NULL);
-- 3. DWD 层明细表(演示用,仅做一层简单清洗)CREATE TABLE IF NOT EXISTS your_name_ecommerce.dwd_detail.orders_detail ASSELECTorder_id,customer_id,phone,product_name,quantity,unit_price,quantity * unit_price AS total_amount,region,order_status,order_time,uidFROM your_name_ecommerce.ods_raw.orders_rawWHERE order_status != 'cancelled';
-- 4. DWS 层汇总表(按地区聚合)CREATE TABLE IF NOT EXISTS your_name_ecommerce.dws_summary.daily_revenue ASSELECTregion,DATE(order_time) AS order_date,SUM(quantity * unit_price) AS total_revenue,COUNT(DISTINCT customer_id) AS unique_customersFROM your_name_ecommerce.ods_raw.orders_rawWHERE order_status != 'cancelled'GROUP BY region, DATE(order_time);
<your_name>_ecommerce。ods_raw Schema,应能看到 orders_raw 表。单击进入表详情页,概览 Tab 中可看到 10 个字段的元数据(名称、类型、描述)。dwd_detail.orders_detail 与 dws_summary.daily_revenue 已注册。CREATE TABLE 权限。详见 结构化数据 Catalog。domain=ecommerce、tier=gold)。domain。ecommerce、finance、logistics。数据资产所属业务域。tier,标签值 :gold / silver / bronze,描述 :资产分层(黄金/白银/青铜)。class.cn_id_card、class.financial_account 等),开箱即用、不可重命名、不可删除。class.cn_mobile_phone,具体命名以平台为准),记下其 Key,供后续步骤使用。<your_name>_ecommerce.dwd_detail.orders_detail 表详情页。domain,标签值 ecommerce。tier,标签值 gold。orders_detail 表详情页 概览 Tab 的字段列表中,找到 phone 字段。phone 字段行末的 添加标签class.cn_mobile_phone,单击 确定 。ods_raw.orders_raw 中的 phone 字段也打上同一个敏感标签。orders_detail 表的 uid 字段上配置「uid 有效期校验」规则,定期检查并在异常时触发告警。dwd_detail.orders_detail 表详情页。<your_name>_ecommerce.dwd_detail.orders_detail。field_rules:- field_name: uidrule_name: uid有效期校验rule_type: custom_sqldimension: validitycustom_sql: SELECT COUNT(*) as check_value FROM ecommerce.dwd_detail.orders_detail WHERE uid IS NOT NULLtrigger_condition: check_value > 0alert:enable: true
field_rule:字段级规则field_name:作用在 uid 字段上。rule_type:模版类型:自定义 SQL。dimension:维度。trigger_condition: check value > 0:检测值大于0 即视为异常。alert enable:规则是否开启告警。 true:表示开启;false:表示不开启。orders_detail_uid_quality。监控订单明细表 uid 字段空值个数,超过 1 触发告警。08:00。orders_detail 的下游加一道质量校验闸门,可在工作流中添加 质量监控任务节点 ,使用动态参数能力配置。字段 | 预期值 |
执行状态 | 成功 |
检测状态 | 异常 |
检测值 | 1 |
阈值 | value <= 0 |
phone 字段已经被打上敏感标签,本步骤把标签关联到具体的脱敏策略,让查询时按用户组返回不同视图;同时为 region 字段配置行级过滤。policy_mobile_phone_mask。class.cn_mobile_phone(关联后所有打了该标签的字段会自动继承 本策略,无需逐字段绑定)。data_admins → 无需配置脱敏策略(管理员看全量)。customer_service → 脱敏方法 保留前4或后4个字符 (客服看 1387********或*******8012)。analysts → 脱敏方法 哈希(分析师看到的值为哈希值)。orders_detail 表添加行级过滤器,让不同地区的运营人员只能看到自己所在地区的订单。dwd_detail.orders_detail 表详情页。ops_north(华北区运营组)。region = 'North'。ops_south → region = 'South'。ops_east_west → region IN ('East', 'West')。analyst_alice 属于 analysts、ops_bob 属于 ops_north),在 SQL 分析中查询:SELECT order_id, phone, region, total_amountFROM your_name_ecommerce.dwd_detail.orders_detailLIMIT 10;
测试账号 | phone 字段返回 | 行可见范围 |
数据治理管理员 | 明文(如 13800138000) | 全部行 |
analyst_alice(属于 analysts) | *** | 全部行 |
ops_bob(属于 ops_north) | 按 analysts 策略未匹配则返回明文(按实际所属用户组而定) | 仅 region = 'North' 的行 |
ops_bob 的 phone 字段返回值取决于其在脱敏策略中的用户组归属。如希望客服组也对手机号脱敏,请回到 5.1 在策略中显式追加该用户组。订单 收入 或 orders_detail,按回车进入全屏数据发现页。domain:ecommerce、tier:gold,结果列表应只剩您本次创建的资产。orders_detail 跳转到表详情页。daily_revenue 是从 orders_raw 经过 orders_detail 加工而来,血缘可以直观追溯整条链路。dws_summary.daily_revenue 表详情页切换到 血缘 Tab。orders_raw、orders_detail 与产出本表的 SQL 任务记录。orders_detail_uid_quality 单击 删除orders_detail 表详情页 权限 Tab 中删除行过滤器;在 数据安全 > 脱敏策略 中取消关联 policy_mobile_phone_mask。orders_detail / orders_raw / daily_revenue 上移除业务标签与敏感标签(系统内置标签本身不可删除,仅解绑)。DROP TABLE IF EXISTS your_name_ecommerce.dws_summary.daily_revenue;DROP TABLE IF EXISTS your_name_ecommerce.dwd_detail.orders_detail;DROP TABLE IF EXISTS your_name_ecommerce.ods_raw.orders_raw;
<your_name>_ecommerce Catalog 详情页右上角 ⋯ > 删除数据目录 。<your_name>_ecommerce(Table 类)在数据目录中可见,包含 ods_raw / dwd_detail / dws_summary 三个 Schema,加上系统的 information_schema 与 default。orders_raw / orders_detail / daily_revenue 三张表均已在 Catalog 中注册,字段元数据与 SQL 一致。domain 与 tier 已创建,敏感标签 class.cn_mobile_phone 已被引用;orders_detail 表已打上业务标签,phone 字段已打上敏感标签。orders_detail_uid_quality 任务处于已发布状态,试运行结果显示检测状态为 异常 (空值率 20%,超出 1% 阈值),任务已挂入工作流按天调度。policy_mobile_phone_mask 脱敏策略已创建并关联 class.cn_mobile_phone;orders_detail 表至少有 1 条行过滤规则。domain:ecommerce 标签筛选能找到本教程产出的全部资产;daily_revenue 的血缘图可向上追溯到 orders_raw。文档反馈