1 简介本文示例代码及文件已上传至我的
Github
仓库https://github.com/CNFeffery/DataScienceStudyNotes
pandas
发展了如此多年,所包含的功能已经覆盖了大部分数据清洗、分析场景,但仍然有着相当一部分的应用场景pandas
中尚存空白亦或是现阶段的操作方式不够简洁方便。
今天我要给大家介绍的Python
库pyjanitor
就内置了诸多功能方法,可以在兼容pandas
中数据框等数据结构的同时为pandas
补充更多功能。它是对R
中著名的数据清洗包janitor
的移植,就如同它的名字那样,帮助我们完成数据处理的清洁工作:
对于使用conda
的朋友,推荐使用下列命令完成pyjanitor
的安装,其中使用到上海交大的conda-forge
镜像:
conda install pyjanitor -c https://mirrors.sjtug.sjtu.edu.cn/anaconda/cloud/conda-forge -y
完成安装后import janitor
即可进行导入,接着我们就可以直接在pandas
的代码逻辑中穿插pyjanitor
的各种API接口。
pyjanitor
中的很多功能实际上跟pandas
中的一些功能存在重叠,作为一位pandas
老手,这部分功能费老师我还是倾向于使用pandas
完成,因此下面我只给大家介绍一些pyjanitor
中颇具特色的功能:
熟悉pandas
链式写法的朋友应该知道这种写法对于处理数据和理清步骤有多高效,pyjanitor
中的also()
方法允许我们在链式过程中随意插入执行任意函数,接受上一步状态的数据框运算结果,且不影响对下一步处理逻辑的数据输入,我非常喜欢这个功能,下面是一个简单的例子:
df = (
# 构造示例数据框
pd.DataFrame({"a": [1, 2, 3], "b": list("abc")})
.query("a > 1")
# 利用also()插入lambda函数接受上一步的输入对象
.also(lambda df: print(f"a字段<=1的记录有{df.query('a <= 1').shape[0]}行"))
.rename(columns={'a': 'new_a'})
# 利用also()实现中间计算结果的导出
.also(lambda df: df.to_csv("temp.csv", index=False))
# 利用also()打印到这一步时数据框计算结果的字段名
.also(
lambda df: print(f"字段名:{df.columns.tolist()}")
)
.drop(columns='b')
)
df
pyjanitor
中的case_when()
方法可以帮助我们针对数据框实现类似SQL
中的的多条件分支运算,注意,因为是多条件分支,所以包含最后的“其他”条件在内,需要至少定义3条分支规则,参考下面的例子:
df = pd.DataFrame(
{
"a": [0, 0, 1, 2],
"b": [0, 3, 4, 5],
"c": [6, 7, 8, 9],
}
)
df.case_when(
((df.a == 0) & (df.b == 0)), '类别1',
((df.a == 0) & (df.b != 0)), '类别2',
# 其他情况
'类别3',
column_name="类别",
)
pyjanitor
中的conditional_join()
非常地好用,它弥补了pandas
一直以来都未完善的“条件连接”功能,即我们对两张表进行连接的条件,不只pandas
中的merge()
、join()
之类的方法所实现的,左表与右表的指定字段之间相等
这样简单的条件判断,而是可高度自定义的条件判断。
conditional_join()
在作为方法使用时,其第一个参数应传入连接中的右表数据框,紧接着的是若干个格式为(左表字段, 右表字段, 判断条件)
这样的三元组来定义单条或多条条件判断的且组合,之后再用于定义连接方式how
参数。
下面是一个示例,这里我们实现生信中常见的一种数据分析操作,左表和右表各自定义了一些区间段,我们利用条件连接来为左表找到右表中完全被其包住的区间:
# 定义示例左表
df_left = pd.DataFrame({
'id': list('abcd'),
'left_range_start': [2, 9, 14, 30],
'left_range_end': [5, 11, 21, 35]
})
# 定义示例右表
df_right = pd.DataFrame({
'id': list('ijxy'),
'right_range_start': [2, 6, 15, 28],
'right_range_end': [3, 10, 18, 31]
})
进行条件连接:
(
df_left
.conditional_join(
df_right,
# 满足left_range_start <= right_range_start
('left_range_start', 'right_range_start', '<='),
# 且满足left_range_end >= right_range_end
('left_range_end', 'right_range_end', '>=')
)
)
连接结果如下:
pyjanitor
中的move()
方法用于快捷调整某行或某列数据的位置,通过source
参数指定需要移动的数据行index
或列的字段名,target
参数用于指定移动的目标位置数据行index
或列的字段名,position
用于设置移动方式('before'
表示移动到目标之前一个位置,after
表示后一个位置),axis
用于设定移动方式(0
表示行移动,1
表示列移动)。
以最常用的列移动为例:
而除了上述这些颇具特色的功能外,pyjanitor
中还针对生信、化学、金融、机器学习、数学等领域内置了一些特别的功能,感兴趣的朋友可以前往其官网https://pyjanitor-devs.github.io/pyjanitor/
进一步了解相关内容。
以上就是本文的全部内容,欢迎在评论区与我进行讨论~