3. 分组汇总 下面继续以前面的销售数据 excel 文件为例。
A. 字段分组 根据某个字段或多个字段实现分组计算,脚本如下:
| A
| B
| 1
| =file(”D:/sales_2013.xlsx”).xlsopen()
|
| 2
| =A1.conj(A1.xlsimport@t(;~.stname))
|
| 3
| =A2.groups('Customer ID';sum('Sale Amount'):Total,avg('Sale Amount'):Average)
|
| 4
| =A2.groups('Customer ID','Purchase Date';sum('Sale Amount'):Total)
|
|
A3的效果:
Customer ID
| Total
| Average
| 1234
| 2550
| 1275.0
| 2345
| 3214
| 1607.0
| 3456
| 2901
| 1450.5
| 4321
| 4132
| 2066.0
| ……
| ……
| ……
| 4567
| 1257
| 1257.0
| A4的效果:
Customer ID
| Purchase Date
| Total
| 1234
| 2013-01-01
| 1200
| 1234
| 2013-03-04
| 1350
| 2345
| 2013-01-11
| 1425
| 2345
| 2013-03-17
| 1789
| ……
| ……
| ……
| 9876
| 2013-02-02
| 1115
| 脚本说明:
A1:打开指定的 excel 文件。
A2:读取并合并文件中所有 sheet 工作表的数据。
A3:在合并后的数据上按字段 'Customer ID' 分组求销售额、平均值
A4:在合并后的数据上按字段 'Customer ID', 'Purchase Date' 分组求销售额
B. 按序分组 集算器在进行分组聚合时还可以和相邻数据行对比,在原数据已经有序时可以不再排序,从而节省时间,并保持原有的次序。假设原数据已经按日期排序,我们想按月份分组统计时,代码如下。
集算器 SPL 脚本:
| A
| B
| 1
| for directory@p(”d:/excel/*.xlsx“)
| =file(A1).xlsopen()
| 2
|
| =B1.conj(B1.xlsimport@t(;~.stname))
| 3
|
| =@|B2
| 4
| =B3.derive(year('Purchase Date'):Year,month('Purchase Date'):Month)
|
| 5
| =A4.groups (month('Purchase Date'):Month;sum('Sale Amount'):Total,avg('Sale Amount'):Average)
|
| 6
| =A4.groups@o (month('Purchase Date'):Month;sum('Sale Amount'):Total,avg('Sale Amount'):Average)
|
|
A5分组效果:
Month
| Total
| Average
| 1
| 272414
| 15134.111111111111
| 2
| 168038
| 9335.444444444445
| 3
| 357693
| 19871.833333333332
| A6分组效果:
Month
| Total
| Average
| 1
| 8992
| 1498.6666666666667
| 2
| 9375
| 1562.5
| 3
| 10139
| 1689.8333333333333
| 1
| 260221
| 43370.166666666664
| 2
| 103656
| 17276.0
| 3
| 101509
| 16918.166666666668
| 1
| 3201
| 533.5
| 2
| 55007
| 9167.833333333334
| 3
| 246045
| 41007.5
|
脚本说明:
A1至 B3:在前面的例子中已经介绍,将同一目录下所有相同结构的 excel 文件的工作表进行合并。
A4:在序表 B3 的基本上重新构造了一个序表 A4,将日期拆分,新增年、月字段。
A5:groups 跨年度按月分组汇总销售额、平均值。
A6:groups@o 按年月分组汇总销售额、平均值, 带参数 @o 实现分组归并处理.
其中,A4 为数据记录明细;A5 按月统计, 不区分年;A6 则按年月统计。这三个单元格中的数据展现出了不同层次的合并汇总结果。
C. 分段分组 将要统计的数据按条件分成几段,统计各组的情况。
集算器 SPL 脚本:
| A
| B
| 1
| for directory@p(”d:/excel/*.xlsx“)
| =file(A1).xlsopen()
| 2
|
| =B1.conj(B1.xlsimport@t(;~.stname))
| 3
|
| =@|B2
| 4
| =B3.groups(if ('Sale Amount'<1000,"1::<1000",
if ('Sale Amount'<1500,"2::1000~~1500",
if ('Sale Amount'<2000,"3::1500~~2000",
if ('Sale Amount'<2500,"4::2000~~2500",
"5::>=2500")))):Segment;
count(1):Number,sum('Sale Amount'):Total)
|
|
分组效果:
Segment
| Number
| Total
| 1::<1000
| 22
| 8280
| 2::1000~~1500
| 9
| 11617
| 3::1500~~2000
| 6
| 10432
| 4::2000~~2500
| 4
| 8810
| 5::>=2500
| 13
| 759006
|
代码说明:
步骤A1到 B3 之间参考前面例子的说明。
A4:字段'Sale Amount'金额的范围分成 5 段,然后累计求出各段的数量及总数。
不过,这样的写法不够方便,如果我们想调整分段方案,就需要修改 groups 函数的参数,而这个参数表达式还是比较复杂的。这时,我们还可以利用集算器中另一个 pseg 函数,更方便地实现这个功能,脚本如下:
| A
| B
| 1
| [0,1000,1500,2000,2500]
|
| 2
| for directory@p(”d:/excel/*.xlsx“)
| =file(A1).xlsopen()
| 3
|
| =B1.conj(B1.xlsimport@t(;~.stname))
| 4
|
| =@|B2
|
| =B4.groups(A1.pseg(~.'Sale Amount'):Segment;
count(1):Number,sum('Sale Amount'):Total)
|
| 当然,我们也可以根据需要,按不同字段不同要求进行分组,然后进行统计处理。例如,在统计班级考生成绩时,各科成绩可划分成优、良、中、差、及格的分数区段,一次为条件进行统计。groups 用法还有很多,可以参考函数手册中相应的章节。 D. 大数据分组 前面的例子中,要读取的 excel 文件都不能很大,也就是都能一次读进内存。手工处理大文件,也会有类似的要求,因为同时打开多个文件,意味着把这些文件都装入内存,很可能会超过机器的物理内存,而用 VBA 读取的情况也差不多。这时,我们就需要用流式的方法读取数据,不需一次读进内存,而是边读取边合并。
集算器 SPL 脚本:
| A
| B
| 1
| =file(“d:/tdata.xlsx”).xlsopen@r()
|
| 2
| for A1.count()
| =A1.xlsimport@ct(;A1(A2). stname)
| 3
|
| =@|B2
| 4
| = B3.conjx()
| =A4.groups('Customer ID';sum('Sale Amount'):SaleTotal)
|
| >file(“d:/out.xlsx”).exportxls@bt(B4;"Customer&Sales")
|
|
筛选分组的效果:
Customer ID
| SaleTotal
| 1234
| 107721792
| 2345
| 139041639
| 3456
| 137985543
| 4321
| 96170742
| ...
| ...
| 9876
| 37590417
|
代码说明:
A1:使用 @r 选项指明以流式打开 excel 文件。
A2:遍历 excel 中的 sheet 工作表。
B2:使用 @c 选项指明以游标方式导入数据。
B3:将游标B2汇集到B3序列中。
A4:将游标序列B3的成员合并到一起组成新的游标。
B4: 序列A4按‘Customer ID’分组累计‘Sale Amount’。
A5:将结果保存。
通过游标以流的方式循环从大文件中读取一段段数据,实现对数据的分组合并。
4. 去重处理 实际数据合并过程中,往往会出现数据重复的现象,重复数据肯定会影响到我们对数据的计算分析。下面介绍使用集算器 SPL 脚本去除重复数据的几种主要解决方法。
A. 主键去重 sales_2013中的数据,设其主键为’Invoice Number’,则根据主键去掉重复记录。
| A
| B
| 1
| =file(“d:/sales_2013.xlsx”).xlsopen()
|
| 2
| =A1.conj(A1.xlsimport@t('Customer Name', 'Invoice Number', 'Sale Amount';~. stname))
|
| 3
| =A2.group@1('Invoice Number')
|
| 4
| >file(“d:/out.xlsx”). xlsexport@t(A3;"result")
|
|
合并去重后的数据:
Customer Name
| Invoice Number
| Sale Amount
| John Smith
| 100-0002
| 1200
| Mary Harrison
| 100-0003
| 1425
| Lucy Gomez
| 100-0004
| 1390
| Rupert Jones
| 100-0005
| 1257
| Jenny Walters
| 100-0006
| 1725
| ……
| ……
| ……
| Susan Wallace
| 100-0019
| 2280
|
代码说明:
A1:打开指定的 excel 文件。
A2:导入 sheet 工作表中指定列的数据。
A3:将序表 A2 按主键' Invoice Number '分组去重处理, 其中参数 @1 表示取每一个分组的第一条记录组成排列后返回(注意是数字 1,不是字母 l)。
A4:将结果保存。
各个 sheet> 中的数据是唯一的,但合并的数据不一定是唯一的,因此采用主键方式去掉重复数据。
B. 某字段去重 根据数据表sales_2013中的某字段去重处理, 查看不同姓名的雇员记录.
| A
| B
| 1
| =file(“d:/sales_2013.xlsx”).xlsopen()
|
| 2
| =A1.conj(A1.xlsimport@t('Customer ID', 'Customer Name';~. stname))
|
| 3
| =A2.id('Customer Name')
|
| 4
| =A2.group@1(' Customer Name')
|
| 5
| >file(“d:/out.xlsx”). xlsexport@t(A4;"result")
|
| 代码说明:
A1:打开指定的 excel 文件。
A2:导入 sheet 工作表中指定列的数据。
A3: 从序表 A2 中获取不重复姓名的记录
A4:从序表 A2中获取不重复姓名的记录列表。
A5:将序表 A4 另存,首行记录为标题。
A3数据去重结果:
Member
| Anushka Vaz
| Daniel Farber
| Harriet Cooper
| ……
| Tony Song
| A4数据去重结果:
Customer ID
| Customer Name
| 5432
| Anushka Vaz
| 9876
| Daniel Farber
| 4321
| Harriet Cooper
| ……
| ……
| 8765
| Tony Song
| C. 联合多字段去重 有的记录虽然有主键,但判断是否为重复的记录,需要用其它几个字段来确定,此时用多个字段联合来确定是否有重复记录.
| A
| B
| 1
| =file(“d:/sales_2013.xlsx”).importxls@t()
|
| 2
| =file(“d:/sales_2014.xlsx”).importxls@t()
|
| 3
| =[A1,A2].merge('Customer ID', 'Purchase Date')
|
| 4
| =A3.group@1('Customer ID', 'Purchase Date')
|
| 5
| >file(“d:/out.xlsx”). xlsexport@t(A4;"result")
|
|
代码说明:
A1:导入指定 excel 文件的数据。
A2:同上。
A3:按字段 'Customer ID', 'Purchase Date' 合并序表 A1,A2,返回序表 A3
A4:序表 A3 按 'Customer ID', 'Purchase Date' 分组去重。 A5:将结果保存。
当然,也可以根据需要,参考更多的字段进行分组合并,去掉重复记录。 D. 记录级去重 解决要合并的每个文件中的记录本身是不重复的,但合并后可能存在重复记录。
| A
| B
| 1
| =file(“d:/sales_2013.xlsx”).importxls@t()
| =A1.group@1('Invoice Number')
| 2
| =file(“d:/sales_2014.xlsx”).importxls@t()
| =A2.group@1('Invoice Number')
| 3
| =[B1,B2].merge@u()
| =A3.count()
| 代码说明:
A1:导入 excel 文件的数据。
B1: 根据字段'Invoice Number'去掉序表 A1中的重复数据
A2、B2:同上。
A3:合并序表 B1,B2 的数据,并去掉重复数据记录返回序表 A3。选项 @u 表示序表成员按顺序合并到一起组成新的序表, 去掉重复的记录。
B3: 查看合并后的数据记录数。
merge@u适合对多序表合并处理, 其中序表内部有序且无重复数据。
本文主要介绍了集算器处理同构 excel 多文件合并、分组汇总数据及数据去重几种情况,在实际工作中,还会遇到异构的情况,只要把需要合并的字段读成集算器的集合对象,后续处理和同构的逻辑是一样的。学会了用这种专业数据处理工具,不仅能合并 Excel 文件, 合并其他文本数据方法也是一致的,再也不用担心合并数据中的多文件、大文件和结构差异问题了。
|