DataLakeCatalog),且当前账号具备 Catalog 的 建库、建表、读写 权限。INSERT 写入数据湖仓。如您的工作空间已有真实业务表,可在 步骤 3 起把表名替换为业务表,跳过 步骤 2 。sales_data 表:字段 | 类型 | 说明 |
date | STRING | 销售日期( YYYY-MM-DD) |
product | STRING | 产品名称 |
region | STRING | 销售大区:North / South / East / West |
quantity | INT | 销售数量 |
revenue | DOUBLE | 销售金额 |
<your_name> 替换成您自己的姓名前缀,例如 alice_database、alice_sales_data。quickstart_sales.sql,选择父文件夹后单击 确定 ,进入 SQL 编辑器。DataLakeCatalog(设置后 SQL 中可省略 Catalog 前缀)。⌘ + Enter,Windows 用户用 Ctrl + Enter):-- 建库(请把 your_name 替换成您自己的姓名前缀)CREATE DATABASE IF NOT EXISTS DataLakeCatalog.your_name_database;
-- 建表CREATE TABLE IF NOT EXISTS DataLakeCatalog.your_name_database.sales_data (date STRING,product STRING,region STRING,quantity INT,revenue DOUBLE);
-- 写入 15 行演示数据INSERT INTO DataLakeCatalog.your_name_database.sales_data VALUES('2025-01-01', 'Widget A', 'North', 239, 6915.68),('2025-01-01', 'Widget B', 'South', 185, 12430.50),('2025-01-01', 'Widget C', 'East', 327, 28025.76),('2025-01-01', 'Widget D', 'North', 340, 8986.75),('2025-01-01', 'Widget E', 'East', 421, 25079.72),('2025-01-02', 'Widget A', 'West', 150, 4350.00),('2025-01-02', 'Widget B', 'North', 275, 18562.50),('2025-01-02', 'Widget C', 'South', 310, 26556.00),('2025-01-02', 'Widget D', 'East', 198, 5237.10),('2025-01-02', 'Widget E', 'West', 460, 27416.00),('2025-01-03', 'Widget A', 'East', 305, 8845.00),('2025-01-03', 'Widget B', 'West', 220, 14850.00),('2025-01-03', 'Widget C', 'North', 290, 24824.00),('2025-01-03', 'Widget D', 'South', 175, 4627.50),('2025-01-03', 'Widget E', 'North', 388, 23124.80);
-- 验证:应返回 15 行SELECT COUNT(*) AS total_rows FROM DataLakeCatalog.your_name_database.sales_data;
DESCRIBE DataLakeCatalog.your_name_database.sales_data;
SELECT * FROM DataLakeCatalog.your_name_database.sales_data LIMIT 10;
Tab | 内容 |
结果 | 查询结果表格,支持排序、显示字段、检索、筛选、复制、下载、可视化。 |
日志 | Spark 执行日志、错误堆栈。 |
代码 | 本次运行的查询语句。 |
-- 各地区销售总览(用作仪表盘 KPI 与柱图数据集)SELECTregion,SUM(quantity) AS total_quantity,SUM(revenue) AS total_revenue,ROUND(AVG(revenue / quantity), 2) AS avg_unit_priceFROM DataLakeCatalog.your_name_database.sales_dataGROUP BY regionORDER BY total_revenue DESC;
-- 每日销售趋势(用作仪表盘折线图数据集)SELECTdate,SUM(revenue) AS daily_revenue,SUM(quantity) AS daily_quantityFROM DataLakeCatalog.your_name_database.sales_dataGROUP BY dateORDER BY date;
-- 各地区内产品销售排名(用作仪表盘表格组件数据集)SELECTregion,product,SUM(revenue) AS product_revenue,RANK() OVER (PARTITION BY region ORDER BY SUM(revenue) DESC) AS revenue_rankFROM DataLakeCatalog.your_name_database.sales_dataGROUP BY region, productORDER BY region, revenue_rank;
-- 参数化:按地区和时间窗口筛选SELECTregion,product,SUM(revenue) AS total_revenueFROM DataLakeCatalog.your_name_database.sales_dataWHERE region = '${target_region}'AND date BETWEEN '${start_date}' AND '${end_date}'GROUP BY region, productORDER BY total_revenue DESC;
target_region=North、start_date=2025-01-01、end_date=2025-01-31 后单击 确定 。⌘ + S)生成一个手动版本(最多保留 200 个),方便日后回滚。单击 收藏 把当前查询加入个人收藏夹,下次打开 SQL 分析首页可一键加载。region。total_revenue,聚合方式选择 不聚合 (SQL 已聚合)。date,Y 轴 daily_revenue。<SQL 文件名>_<查询 ID>_<时间>.<ext> 命名后下载到本地。销售业绩日报 - <your_name>。ds_region_summary。数据集名称 | 来源 SQL |
ds_region_summary | 3.2 按地区聚合 |
ds_daily_trend | 3.3 每日销售趋势 |
ds_product_rank | 3.4 窗口排名 |
ds_detail | SELECT * FROM DataLakeCatalog.your_name_database.sales_data |
ds_region_summary。total_revenue,计算方式选择 求和 。总收入,样式中类型选择 自定义 - 货币 。ds_region_summary。region。total_revenue,计算方式 不聚合 (SQL 已聚合)。各地区销售收入。ds_daily_trend。date。daily_revenue(可同时加入 daily_quantity 作为副 Y 轴)。每日销售趋势。ds_product_rank。region、product、product_revenue、revenue_rank 。各地区产品 TOP 排行。ds_region_summary.region。quickstart_sales.sql 在 SQL 分析中可见,已保存至少 1 个手动版本。DataLakeCatalog.<your_name>_database.sales_data 中有 15 行数据,4 类聚合 SQL 均可成功运行并产出结果。销售业绩日报 - <your_name> 在仪表盘列表可见,状态为 已发布 。文档反馈