10分钟ToPandas_0.24.2
Posted i201102053
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了10分钟ToPandas_0.24.2相关的知识,希望对你有一定的参考价值。
# Author:Zhang Yuan整理,版本Pandas0.24.2 # 0. 习惯上,我们会按下面格式引入所需要的包: import pandas as pd import numpy as np import matplotlib.pyplot as plt # 1. 创建对象 Object Creation--------------------------------------------------------------- # 可以通过 数据结构入门 来查看有关该节内容的详细信息。 # 1.1 可以通过传递一个 list 对象来创建一个 Series ,pandas 会默认创建整型索引: s = pd.Series([1,3,5,np.nan,6,8]) s # 1.2 通过传递一个 numpy array ,时间索引以及列标签来创建一个 DataFrame : dates = pd.date_range(‘20130101‘, periods=6) dates df = pd.DataFrame(np.random.randn(6, 4), index=dates, columns=list(‘ABCD‘)) df # 1.3 通过传递一个能够被转换成类似序列结构的字典对象来创建一个 DataFrame : df2 = pd.DataFrame({ ‘A‘: 1., ‘B‘: pd.Timestamp(‘20130102‘), ‘C‘: pd.Series(1, index=list(range(5)), dtype=‘float32‘), ‘D‘: np.array([3] * 5, dtype=‘int32‘), ‘E‘: pd.Categorical(["test", "train", "test", "train","add"]), ‘F‘: ‘foo‘ }) df2 # 1.4 查看不同列的数据类型: df2.dtypes # 2. 查看数据Viewing Data--------------------------------------------------- # 2.1 查看 DataFrame 中头部和尾部的行:十分钟搞定 Pandas df.head() df.tail(3) # 2.2 显示索引. 列和底层的 numpy 数据: df.index df.columns df.values # 2.3 DataFrame.to_numpy()给出了底层数据的NumPy表示。 请注意,当您的DataFrame具有不同数据类型的列时,他可能是一项昂贵的操作,这归结为pandas和NumPy之间的根本区别:NumPy数组对整个数组有一个dtype,而pandas DataFrames每列有一个dtype。 当您调用DataFrame.to_numpy()时,pandas将找到可以容纳DataFrame中所有dtypes的NumPy dtype。 这可能最终成为对象,这需要将每个值都转换为Python对象。 df.to_numpy() # 对于df,我们的所有浮点值的DataFrame,DataFrame.to_numpy()都很快,不需要复制数据。 df2.to_numpy()# 对于df2,具有多个dtypes的DataFrame,DataFrame.to_numpy()相对昂贵。 # 2.4 describe() 函数对于数据的快速统计汇总: df.describe() # 2.5 对数据的转置: df.T # 2.6 按轴进行排序: df.sort_index(axis=1, ascending=False) # 2.7 按值进行排序: df.sort_values(by=‘B‘) # 3. 选择Selection----------------------------------------------------------------- # 虽然标准的 Python/Numpy 的选择和设置表达式都能够直接派上用场,但是作为工程使用的代码,我们推荐使用经过优化的 pandas 数据访问方式: .at , .iat ,.loc , .iloc。 # 3.1 获取Getting # 3.1.1 选择一个单独的列,这将会返回一个 Series ,等同于 df.A : df[‘A‘] # 3.1.2 通过 [] 进行选择,这将会对行进行切片 df[0:3] df[‘20130102‘:‘20130104‘] # 3.2 通过标签选择Selection by Label # 3.2.1 使用标签来获取一个交叉的区域 df.loc[dates[0]] # 3.2.2 通过标签来在多个轴上进行选择 df.loc[:, [‘A‘, ‘B‘]] # 3.2.3 标签切片 df.loc[‘20130102‘:‘20130104‘, [‘A‘, ‘B‘]] # 3.2.4 对于返回的对象进行维度缩减 df.loc[‘20130102‘, [‘A‘, ‘B‘]] # 3.2.5 获取一个标量 df.loc[dates[0], ‘A‘] # 3.2.6 快速访问一个标量(与上一个方法等价) df.at[dates[0], ‘A‘] # 3.3 通过位置选择Selection by Position # 3.3.1 通过传递数值进行位置选择(选择的是行) df.iloc[3] # 3.3.2 通过数值进行切片,与 numpy/python 中的情况类似 df.iloc[3:5, 0:2] # 3.3.3 通过指定一个位置的列表,与 numpy/python 中的情况类似 df.iloc[[1, 2, 4], [0, 2]] # 3.3.4 对行进行切片 df.iloc[1:3, :] # 3.3.5 对列进行切片 df.iloc[:, 1:3] # 3.3.6 获取特定的值 df.iloc[1, 1] # 3.3.7 快速访问标量(等同于前一个方法): df.iat[1, 1] # 3.4 布尔索引 Boolean Indexing # 3.4.1 使用一个单独列的值来选择数据: df[df.A > 0] # 3.4.2 使用 where 操作来选择数据: df[df > 0] # 3.4.3 使用 isin() 方法来过滤: df2 = df.copy() df2[‘E‘] = [‘one‘, ‘one‘, ‘two‘, ‘three‘, ‘four‘, ‘three‘] df2 df2[df2[‘E‘].isin([‘two‘, ‘four‘])] # 3.5 设置Setting # 3.5.1 设置一个新的列: s1 = pd.Series([1, 2, 3, 4, 5, 6], index=pd.date_range(‘20130102‘, periods=6)) s1 # 3.5.2 通过标签设置新的值: df.at[dates[0], ‘A‘] = 0 # 3.5.3 通过位置设置新的值: df.iat[0, 1] = 0 # 3.5.4 通过一个numpy数组设置一组新值: df.loc[:, ‘D‘] = np.array([5] * len(df)) df # 3.5.5 通过where操作来设置新的值: df2 = df.copy() df2[df2 > 0] = -df2 df2 # 4. 缺失值处理Missing Data--------------------------------------------------------------- # 在 pandas 中,使用 np.nan 来代替缺失值,这些值将默认不会包含在计算中,详情请参阅:缺失的数据。 # 4.1 reindex() 方法可以对指定轴上的索引进行改变/增加/删除操作,这将返回原始数据的一个拷贝: df1 = df.reindex(index=dates[0:4], columns=list(df.columns) + [‘E‘]) df1.loc[dates[0]:dates[1], ‘E‘] = 1 df1 # 4.2 去掉包含缺失值的行: df1.dropna(how=‘any‘) # 4.3 对缺失值进行填充: df1.fillna(value=5) # 4.4 对数据进行布尔填充: pd.isna(df1) # 5. 相关操作Operations------------------------------------------------------------------ # 详情请参与 基本的二进制操作 # 5.1 统计(相关操作通常情况下不包括缺失值). # 5.1.1 执行描述性统计: df.mean() # 5.1.2 在其他轴上进行相同的操作: df.mean(1) # 5.1.3 对于拥有不同维度,需要对齐的对象进行操作。Pandas 会自动的沿着指定的维度进行广播: s = pd.Series([1, 3, 5, np.nan, 6, 8], index=dates).shift(2) df.sub(s, axis=‘index‘) # 5.2 应用Apply # 对数据应用函数: df.apply(np.cumsum) df.apply(lambda x: x.max() - x.min()) # 5.3直方图 s = pd.Series(np.random.randint(0, 7, size=10)) s s.value_counts() # 5.4字符串方法 # Series 对象在其 str 属性中配备了一组字符串处理方法,可以很容易的应用到数组中的每个元素,如下段代码所示。更多详情请参考:字符串向量化方法。 s = pd.Series([‘A‘, ‘B‘, ‘C‘, ‘Aaba‘, ‘Baca‘, np.nan, ‘CABA‘, ‘dog‘, ‘cat‘]) s.str.lower() # 6. 合并Merge--------------------------------------------------------------------------- # 6.1 Concat # Pandas 提供了大量的方法能够轻松的对 Series , DataFrame 和 Panel 对象进行各种符合各种逻辑关系的合并操作。具体请参阅:合并。 # 使用concat()连接pandas对象: df = pd.DataFrame(np.random.randn(10, 4)) df pieces = [df[:3], df[3:7], df[7:]] pd.concat(pieces) # 6.2 Join # 类似于 SQL 类型的合并,具体请参阅:数据库风格的连接 left = pd.DataFrame({‘key‘: [‘foo‘, ‘foo‘], ‘lval‘: [1, 2]}) right = pd.DataFrame({‘key‘: [‘foo‘, ‘foo‘], ‘rval‘: [4, 5]}) left right pd.merge(left, right, on=‘key‘) # 另一个例子: left = pd.DataFrame({‘key‘: [‘foo‘, ‘bar‘], ‘lval‘: [1, 2]}) right = pd.DataFrame({‘key‘: [‘foo‘, ‘bar‘], ‘rval‘: [4, 5]}) left right pd.merge(left, right, on=‘key‘) # 6.3Append # 将一行连接到一个 DataFrame 上,具体请参阅附加: df = pd.DataFrame(np.random.randn(8, 4), columns=[‘A‘, ‘B‘, ‘C‘, ‘D‘]) df s = df.iloc[3] df.append(s, ignore_index=True) # 7. 分组Grouping------------------------------------------------------------------------------ # 对于”group by”操作,我们通常是指以下一个或多个操作步骤: # (Splitting)按照一些规则将数据分为不同的组; # (Applying)对于每组数据分别执行一个函数; # (Combining)将结果组合到一个数据结构中; df = pd.DataFrame({‘A‘: [‘foo‘, ‘bar‘, ‘foo‘, ‘bar‘, ‘foo‘, ‘bar‘, ‘foo‘, ‘foo‘], ‘B‘: [‘one‘, ‘one‘, ‘two‘, ‘three‘, ‘two‘, ‘two‘, ‘one‘, ‘three‘], ‘C‘: np.random.randn(8), ‘D‘: np.random.randn(8)}) df # 7.1 分组并对每个分组执行 sum 函数: df.groupby(‘A‘).sum() # 7.2 通过多个列进行分组形成一个层次索引,然后执行函数: df.groupby([‘A‘, ‘B‘]).sum() # 8. 改变形状Reshaping------------------------------------------------------------------------- # 详情请参阅 层次索引 和 改变形状。 # 8.1 栈方法 Stack ,二维数据与多索引的一维数据之间转变 tuples = list(zip(*[[‘bar‘, ‘bar‘, ‘baz‘, ‘baz‘,‘foo‘, ‘foo‘, ‘qux‘, ‘qux‘], [‘one‘, ‘two‘, ‘one‘, ‘two‘,‘one‘, ‘two‘, ‘one‘, ‘two‘], [‘a‘, ‘b‘, ‘a‘, ‘b‘,‘a‘, ‘b‘, ‘a‘, ‘b‘]])) index = pd.MultiIndex.from_tuples(tuples, names=[‘first‘, ‘second‘,"third"]) #三重索引 df = pd.DataFrame(np.random.randn(8, 2), index=index, columns=[‘A‘, ‘B‘]) df2 = df[:4] df2 # 8.1.1 stack()方法“压缩”DataFrame列中的级别(具有MultiIndex作为索引)。 stacked = df2.stack() #列转成索引,变成更多index的一维数据 stacked # 8.1.2 使用“stacked”DataFrame或Series(具有MultiIndex作为索引),stack()的反向操作是unstack(),默认情况下取消堆栈最后一级: stacked.unstack() #默认最后一级索引变成列 stacked.unstack(1) #第二层变成列 stacked.unstack(0) #第一层变成列 # 8.2 数据透视表 Pivot Tables (其实就是把内容作为索引来展示二维数据) df = pd.DataFrame({ ‘A‘: [‘one‘, ‘one‘, ‘two‘, ‘three‘] * 3, ‘B‘: [‘AA‘, ‘BB‘, ‘CC‘] * 4, ‘C‘: [‘foo‘, ‘foo‘, ‘foo‘, ‘bar‘, ‘bar‘, ‘bar‘] * 2, ‘D‘: np.random.randn(12), ‘E‘: np.random.randn(12)}) df # 可以从这个数据中轻松的生成数据透视表: pd.pivot_table(df, values=‘D‘, index=[‘A‘, ‘B‘], columns=[‘C‘]) # 9. 时间序列-------------------------------------------------------------------------------- # Pandas 在对频率转换进行重新采样时拥有简单、强大且高效的功能(如将按秒采样的数据转换为按5分钟为单位进行采样的数据)。这种操作在金融领域非常常见。具体参考:时间序列。 rng = pd.date_range(‘1/1/2012‘, periods=100, freq=‘S‘) ts = pd.Series(np.random.randint(0, 500, len(rng)), index=rng) ts.resample(‘5Min‘).sum() #转成5min数据 # 9.1 时区表示: rng = pd.date_range(‘3/6/2012 00:00‘, periods=5, freq=‘D‘) ts = pd.Series(np.random.randn(len(rng)), rng) ts ts_utc = ts.tz_localize(‘UTC‘) ts_utc # 9.2 时区转换: ts_utc.tz_convert(‘US/Eastern‘) # 9.3 时间跨度转换: rng = pd.date_range(‘1/1/2012‘, periods=5, freq=‘M‘) ts = pd.Series(np.random.randn(len(rng)), index=rng) ts ps = ts.to_period() ps ps.to_timestamp() # 9.4 时期和时间戳之间的转换使得可以使用一些方便的算术函数。 prng = pd.period_range(‘1990Q1‘, ‘2000Q4‘, freq=‘Q-NOV‘) ts = pd.Series(np.random.randn(len(prng)), prng) ts.index = (prng.asfreq(‘M‘, ‘e‘) + 1).asfreq(‘H‘, ‘s‘) + 9 ts.head() # 10. 分类 Categorical # pandas 可以在 DataFrame 中支持 Categorical 类型的数据 df = pd.DataFrame({"id": [1, 2, 3, 4, 5, 6], "raw_grade": [‘a‘, ‘b‘, ‘b‘, ‘a‘, ‘a‘, ‘e‘]}) # 10.1 将原始的 grade 转换为 Categorical 数据类型: df["grade"] = df["raw_grade"].astype("category") df["grade"] # 10.2 将 Categorical 类型数据重命名为更有意义的名称: df["grade"].cat.categories = ["very good", "good", "very bad"] # 10.3 对类别进行重新排序,增加缺失的类别: df["grade"] = df["grade"].cat.set_categories(["very bad", "bad", "medium", "good", "very good"]) df["grade"] # 10.4 排序是按照 Categorical 的顺序进行的而不是按照字典顺序进行: df.sort_values(by="grade") # 10.5 对 Categorical 列进行排序,也存在空的类别: df.groupby("grade").size() # 11. 画图 Plotting---------------------------------------------------------- ts = pd.Series(np.random.randn(1000),index=pd.date_range(‘1/1/2000‘, periods=1000)) ts = ts.cumsum() ts.plot();plt.show() # 11.1 对于 DataFrame 来说, plot 是一种将所有列及其标签进行绘制的简便方法: df = pd.DataFrame(np.random.randn(1000, 4), index=ts.index,columns=[‘A‘, ‘B‘, ‘C‘, ‘D‘]) df = df.cumsum() plt.figure() df.plot() plt.legend(loc=‘best‘);plt.show() # 12. 导入和保存数据 Getting Data In/Out---------------------------------------- import os # 目录引导结果在Console和run结果不同 print("os.getcwd():",os.getcwd()) print("abspath:",os.path.abspath("11.10MinutesToPandas0.24.2.py")) # 12.1.1 写入 csv 文件: df.to_csv("foo.csv") # 12.1.2 从 csv 文件中读取: pd.read_csv("foo.csv") # 12.2 HDF5 # 12.2.1 写入 HDF5 存储: df.to_hdf(‘foo.h5‘, ‘df‘) # 12.2.2 从 HDF5 存储中读取: pd.read_hdf(‘foo.h5‘, ‘df‘) # 12.3 Excel # 12.3.1 写入excel文件: df.to_excel(‘foo.xlsx‘, sheet_name=‘Sheet1‘) # 12.3.2 从excel文件中读取: pd.read_excel(‘foo.xlsx‘, ‘Sheet1‘, index_col=None, na_values=[‘NA‘]) # 13. 陷阱 Gotchas-------------------------------------------------------- # 如果你尝试某个操作并且看到如下异常:(不能以Series化格式进行bool判定) # if pd.Series([False, True, False]): # print("I was true")
以上是关于10分钟ToPandas_0.24.2的主要内容,如果未能解决你的问题,请参考以下文章
toPandas() 在 Jupyter iPython Notebook 上工作,但提交失败 - AWS EMR
toPandas() 会随着 pyspark 数据框变小而加快速度吗?
使用 pyspark 的 toPandas() 错误:'int' 对象不可迭代