当前位置: 首页 > news >正文

Pandas 合并数据集:concat 和 append

文章目录

  • Pandas 合并数据集:concat 和 append
    • 回顾:NumPy 数组的拼接
    • 使用 pd.concat 进行简单拼接
      • 重复索引
        • 将重复索引视为错误
        • 忽略索引
        • 添加多级索引(MultiIndex)键
      • 使用连接(Join)方式拼接
      • append 方法

Pandas 合并数据集:concat 和 append

封面

一些最有趣的数据研究来自于合并不同的数据源。
这些操作可以包括从非常简单的两个数据集的拼接,到更复杂的数据库式连接和合并,这些操作能够正确处理数据集之间的重叠部分。
SeriesDataFrame 都是为这种操作设计的,Pandas 提供了函数和方法,使得这种数据整理变得快速且简单。

在这里,我们将首先介绍如何使用 pd.concat 函数对 SeriesDataFrame 进行简单拼接;稍后我们会深入讲解 Pandas 中更复杂的内存合并和连接操作。

我们从标准的导入开始:

import pandas as pd
import numpy as np

为了方便起见,我们将定义一个函数,用于创建特定格式的 DataFrame,这将在接下来的示例中非常有用。

# 快速创建DataFrame
def make_df(cols, ind):"""快速创建一个DataFrame"""data = {c: [str(c) + str(i) for i in ind]for c in cols}return pd.DataFrame(data, ind)# 创建一个示例DataFrame
df1 = make_df(['A', 'B', 'C'], [1, 2])
df2 = make_df(['A', 'B', 'C'], [3, 4])
df1
ABC
1A1B1C1
2A2B2C2
df2
ABC
3A3B3C3
4A4B4C4
make_df('ABC', range(3))
ABC
0A0B0C0
1A1B1C1
2A2B2C2

此外,我们还将创建一个快速类,用于让我们能够并排显示多个 DataFrame。该代码利用了特殊的 _repr_html_ 方法,这是 IPython/Jupyter 用于实现其丰富对象显示的机制:

class display(object):"""Display HTML representation of multiple objects"""template = """<div style="float: left; padding: 10px;"><p style='font-family:"Courier New", Courier, monospace'>{0}</p>{1}</div>"""def __init__(self, *args):self.args = argsdef _repr_html_(self):return '\n'.join(self.template.format(a, eval(a)._repr_html_())for a in self.args)def __repr__(self):return '\n\n'.join(a + '\n' + repr(eval(a))for a in self.args)

随着我们在接下来的章节中继续讨论,这个类的用途将会变得更加清晰。

回顾:NumPy 数组的拼接

SeriesDataFrame 对象的拼接行为类似于 NumPy 数组的拼接,可以通过 np.concatenate 函数实现,相关内容可参考 NumPy 数组基础。
回顾一下,使用该函数可以将两个或多个数组的内容合并为一个数组:

x = [1, 2, 3]
y = [4, 5, 6]
z = [7, 8, 9]
np.concatenate([x, y, z])
array([1, 2, 3, 4, 5, 6, 7, 8, 9])

第一个参数是要连接的数组的列表或元组。
此外,对于多维数组,还可以使用 axis 关键字参数,指定沿哪个轴进行拼接:

x = [[1, 2],[3, 4]]
np.concatenate([x, x], axis=1)
array([[1, 2, 1, 2],[3, 4, 3, 4]])

使用 pd.concat 进行简单拼接

pd.concat 函数提供了类似于 np.concatenate 的语法,但包含了许多我们稍后会讨论的选项:

# Pandas v1.3.5 中的函数签名
pd.concat(objs, axis=0, join='outer', ignore_index=False, keys=None,levels=None, names=None, verify_integrity=False,sort=False, copy=True)

pd.concat 可以用于简单地拼接 SeriesDataFrame 对象,就像 np.concatenate 可以用于简单地拼接数组一样:

ser1 = pd.Series(['A', 'B', 'C'], index=[1, 2, 3])
ser2 = pd.Series(['D', 'E', 'F'], index=[4, 5, 6])
pd.concat([ser1, ser2])
1    A
2    B
3    C
4    D
5    E
6    F
dtype: object

它同样适用于拼接更高维度的对象,比如 DataFrame

df1 = make_df('AB', [1, 2])
df2 = make_df('AB', [3, 4])
display('df1', 'df2', 'pd.concat([df1, df2])')

df1

AB
1A1B1
2A2B2

df2

AB
3A3B3
4A4B4

pd.concat([df1, df2])

AB
1A1B1
2A2B2
3A3B3
4A4B4

它的默认行为是在 DataFrame 内按行拼接(即 axis=0)。
np.concatenate 类似,pd.concat 允许指定拼接所沿的轴。
请看下面的例子:

df3 = make_df('AB', [0, 1])
df4 = make_df('CD', [0, 1])
display('df3', 'df4', "pd.concat([df3, df4], axis='columns')")

df3

AB
0A0B0
1A1B1

df4

CD
0C0D0
1C1D1

pd.concat([df3, df4], axis='columns')

ABCD
0A0B0C0D0
1A1B1C1D1

我们同样可以指定 axis=1;这里我们使用了更直观的 axis='columns'

重复索引

np.concatenatepd.concat 之间的一个重要区别是,Pandas 的拼接操作会保留索引,即使结果中会出现重复的索引!
请看下面这个简短的例子:

x = make_df('AB', [0, 1])
y = make_df('AB', [2, 3])
y.index = x.index  # make indices match
display('x', 'y', 'pd.concat([x, y])')

x

AB
0A0B0
1A1B1

y

AB
0A2B2
1A3B3

pd.concat([x, y])

AB
0A0B0
1A1B1
0A2B2
1A3B3

注意结果中重复的索引。
虽然在 DataFrame 中这是允许的,但这种结果通常并不是我们想要的。
pd.concat 为我们提供了几种处理这种情况的方法。

将重复索引视为错误

如果你希望在 pd.concat 的结果中索引没有重叠,可以设置 verify_integrity 参数为 True
这样拼接时如果出现重复索引,就会抛出异常。
下面是一个示例,为了更清晰,我们会捕获并打印错误信息:

try:pd.concat([x, y], verify_integrity=True)
except ValueError as e:print("ValueError:", e)
ValueError: Indexes have overlapping values: Index([0, 1], dtype='int64')
忽略索引

有时候索引本身并不重要,你可能更希望直接忽略它。
可以通过设置 ignore_index 参数来实现这一点。
当该参数设为 True 时,拼接后的结果会为新的 DataFrame 创建一个新的整数索引:

display('x', 'y', 'pd.concat([x, y], ignore_index=True)')

x

AB
0A0B0
1A1B1

y

AB
0A2B2
1A3B3

pd.concat([x, y], ignore_index=True)

AB
0A0B0
1A1B1
2A2B2
3A3B3
添加多级索引(MultiIndex)键

另一种选择是使用 keys 选项为数据源指定标签;结果将是一个包含这些数据的分层索引(MultiIndex)序列:

display('x', 'y', "pd.concat([x, y], keys=['x', 'y'])")

x

AB
0A0B0
1A1B1

y

AB
0A2B2
1A3B3

pd.concat([x, y], keys=['x', 'y'])

AB
x0A0B0
1A1B1
y0A2B2
1A3B3

我们可以使用分层索引中讨论的工具,将这个多重索引的 DataFrame 转换为我们感兴趣的表示形式。

使用连接(Join)方式拼接

在前面的简短示例中,我们主要拼接的是具有相同列名的 DataFrame
实际上,来自不同数据源的数据可能具有不同的列集合,此时 pd.concat 提供了多种选项。
请看下面两个 DataFrame 的拼接示例,它们只有部分(而不是全部)列名相同:

df5 = make_df('ABC', [1, 2])
df6 = make_df('BCD', [3, 4])
display('df5', 'df6', 'pd.concat([df5, df6])')

df5

ABC
1A1B1C1
2A2B2C2

df6

BCD
3B3C3D3
4B4C4D4

pd.concat([df5, df6])

ABCD
1A1B1C1NaN
2A2B2C2NaN
3NaNB3C3D3
4NaNB4C4D4

默认行为是用 NA 值填充没有数据的位置。
要更改这一点,我们可以调整 concat 函数的 join 参数。
默认情况下,join 是输入列的并集(join='outer'),但我们也可以通过设置 join='inner',将其改为只保留列的交集:

display('df5', 'df6',"pd.concat([df5, df6], join='inner')")

df5

ABC
1A1B1C1
2A2B2C2

df6

BCD
3B3C3D3
4B4C4D4

pd.concat([df5, df6], join='inner')

BC
1B1C1
2B2C2
3B3C3
4B4C4

另一种有用的模式是在拼接前使用 reindex 方法,以更精细地控制哪些列被舍弃:

pd.concat([df5, df6.reindex(df5.columns, axis=1)])
ABC
1A1B1C1
2A2B2C2
3NaNB3C3
4NaNB4C4

append 方法

由于直接拼接数组非常常见,在Pandas 2.0.0版本之前,SeriesDataFrame 对象都提供了 append 方法,可以用更少的代码实现同样的功能。
但值得注意的是,自 Pandas 2.0.0 开始,不再支持append方法,故以下的示例将报 AttributeError。

display('df1', 'df2', 'df1.append(df2)')

请注意,与 Python 列表的 appendextend 方法不同,Pandas 中的 append 方法不会修改原始对象;它会创建一个包含合并数据的新对象。
此外,这种方法的效率并不高,因为它涉及新索引和数据缓冲区的创建。
因此,如果你打算进行多次 append 操作,通常更好的做法是先构建一个 DataFrame 对象的列表,然后一次性传递给 concat 函数。

Pandas有更强大的多数据源合并方法:pd.merge 实现的数据库式合并/连接。
关于 concatappend 及相关功能的更多信息,请参阅 Pandas 文档的“合并、连接、拼接与比较”部分。

http://www.dtcms.com/a/344427.html

相关文章:

  • 2025年城市建设与公共管理国际会议(UCPM 2025)
  • Linux之Ubuntu入门:Vmware中虚拟机中的Ubuntu中的shell命令-常用命令
  • C++实现简易线程池:理解 function 与 bind 的妙用
  • CMake进阶:Ninja环境搭建与加速项目构建
  • JVM-(8)JVM启动的常用命令以及参数
  • 期货Level-2五档订单簿每250毫秒高频数据及分时、日度历史行情深度解析
  • 【大模型采样策略(Greedy、Top-k、Top-p、温度调节)三化学习】
  • 旧物新生,交易无界——探索二手交易小程序系统的绿色革命
  • 优考试局域网系统V6.0.0版
  • 谁才是多快好省的数据分析选择:SelectDB vs. ClickHouse vs. Snowflake
  • 关于常用线程池CompletableFuture和Future的介绍
  • 我从零开始学习C语言(13)- 循环语句 PART2
  • QT-左右侧边栏动画
  • 动态代理保姆级别
  • 大模型微调:从理论到实践的全面指南
  • 数据结构与算法之数组篇leetcode704 - 二分查找
  • kubernetes中pod的管理及优化
  • Spring Boot 自动配置全流程深度解析
  • Linux虚拟机安装FTP
  • 「越短越合法」型滑动窗口
  • Seaborn数据可视化实战:Seaborn基础图表绘制入门
  • 分布式日志分析平台(ELFK 与 EFK)理论
  • 【机器学习深度学习】大模型分布式推理概述:从显存困境到高并发挑战的解决方案
  • 技术干货|使用Prometheus+Grafana监控Tomcat实例详解
  • [特殊字符] TTS格局重塑!B站推出Index-TTS,速度、音质、情感表达全维度领先
  • TTC协议(TTS即ORACLE DATA)协议分析
  • 代码随想录刷题Day40
  • week3-[二维数组]最大列
  • 文件系统层面的可用块数量可用空间和比例
  • 【Python-Day 40】告别内存溢出!Python 生成器 (Generator) 的原理与实战