ToB企服应用市场:ToB评测及商务社交产业平台

标题: pandas替换，加载，透视表 [打印本页]

---

作者: 风雨同行    时间: 2022-12-21 01:28
标题: pandas替换，加载，透视表
pandas的级联和合并

级联操作

• pd.concat, pd.append
  

pandas使用pd.concat函数，与np.concatenate函数类似，只是多了一些参数：

1. objs
2. axis=0
3. keys
4. join='outer' / 'inner':表示的是级联的方式，outer会将所有的项进行级联（忽略匹配和不匹配），而inner只会将匹配的项级联到一起，不匹配的不级联
5. ignore_index=False

复制代码

• 匹配级联
  1. df1 = pd.DataFrame(data=np.random.randint(0,100,size=(5,3)),columns=['A','B','C'])
  2. df2 = pd.DataFrame(data=np.random.randint(0,100,size=(5,3)),columns=['A','D','C'])
  3. pd.concat((df1,df1),axis=1) #行列索引都一致的级联叫做匹配级联

  复制代码
  
  
• 不匹配级联
  
  
  
  • 不匹配指的是级联的维度的索引不一致。例如纵向级联时列索引不一致，横向级联时行索引不一致
    
  • 有2种连接方式：
    
    
    
    • 外连接：补NaN（默认模式）
      1. pd.concat((df1,df2),axis=0) or pd.concat((df1,df2),axis=1, join='outer')

      复制代码
      
      
    • 内连接：只连接匹配的项
      1. pd.concat((df1,df2),axis=0,join='inner') #inner直把可以级联的级联不能级联不处理

      复制代码
      
      

      
      

      
      
      • 如果想要保留数据的完整性必须使用outer（外连接）
        
      • append函数的使用
        

      
      
    
    
  
  
• append函数的使用
  1. df1.append(df1)

  复制代码

合并操作

• merge与concat的区别在于merge需要依据某一共同列来进行合并
  
• 使用pd.merge()合并时，会自动根据两者相同column名称的那一列，作为key来进行合并。
  
• 注意每一列元素的顺序不要求一致
  

1. df1 = DataFrame({'employee':['regina','ivanlee','baby'],
2.                 'group':['Accounting','Engineering','Engineering'],
3.                 })
4. df2 = DataFrame({'employee':['regina','ivanlee','baby'],
5.                 'hire_date':[2004,2008,2012],
6.                 })
9. pd.merge(df1,df2,on='employee')

复制代码

一对多合并

1. df3 = DataFrame({
2.     'employee':['regina','ivanlee'],
3.     'group':['Accounting','Engineering'],
4.     'hire_date':[2004,2016]})
6. df4 = DataFrame({'group':['Accounting','Engineering','Engineering'],
7.                        'supervisor':['Carly','Guido','Steve']
8.                 })
9. pd.merge(df3,df4)#on如果不写，默认情况下使用两表中公有的列作为合并条件

复制代码

多对多合并

1. df5 = DataFrame({'group':['Accounting','Engineering','HR'],
2.                 'supervisor':['Carly','Guido','Steve']
3.                 })

复制代码

how 参数默认是inner，也可以是outer，right，left

key的规范化

• 当两张表没有可进行连接的列时，可使用left_on和right_on手动指定merge中左右两边的哪一列列作为连接的列
  1. df5 = DataFrame({'name':['ivanlee','zjr','liyifan'],
  2.                 'hire_dates':[1998,2016,2007]})
  5. pd.merge(df1,df5,left_on='employee',right_on='name')

  复制代码
  
  

内合并与外合并:out取并集 inner取交集

人口分析项目

• 需求：
  
  
  
  • 导入文件，查看原始数据
    
  • 将人口数据和各州简称数据进行合并
    
  • 将合并的数据中重复的abbreviation列进行删除
    
  • 查看存在缺失数据的列
    
  • 找到有哪些state/region使得state的值为NaN，进行去重操作
    
  • 为找到的这些state/region的state项补上正确的值，从而去除掉state这一列的所有NaN
    
  • 合并各州面积数据areas
    
  • 我们会发现area(sq.mi)这一列有缺失数据，找出是哪些行
    
  • 去除含有缺失数据的行
    
  • 找出2010年的全民人口数据
    
  • 计算各州的人口密度
    
  • 排序，并找出人口密度最高的州
    
  
  

1. #导入文件，查看原始数据
2. abb = pd.read_csv('../data/state-abbrevs.csv') #state(州的全称)abbreviation（州的简称）
3. area = pd.read_csv('../data/state-areas.csv') #state州的全称，area (sq. mi)州的面积
4. pop = pd.read_csv('../data/state-population.csv')#state/region简称，ages年龄，year时间，population人口数量

复制代码

1. #将人口数据和各州简称数据进行合并
2. abb_pop = pd.merge(abb,pop,left_on='abbreviation',right_on='state/region',how='outer') 必须保证数据完整
3. abb_pop.head()

复制代码

1. #将合并的数据中重复的abbreviation列进行删除
2. abb_pop.drop(labels='abbreviation',axis=1,inplace=True)
4. #查看存在缺失数据的列
5. #方式1：isnull，notll，any，all
6. abb_pop.isnull().any(axis=0)
7. #state,population这两列中是存在空值

复制代码

1. #1.将state中的空值定位到
2. abb_pop['state'].isnull()
3. #2.将上述的布尔值作为源数据的行索引
4. abb_pop.loc[abb_pop['state'].isnull()]#将state中空对应的行数据取出
5. #3.将简称取出
6. abb_pop.loc[abb_pop['state'].isnull()]['state/region']
7. #4.对简称去重
8. abb_pop.loc[abb_pop['state'].isnull()]['state/region'].unique()
10. #结论：只有PR和USA对应的全称数据为空值

复制代码

1. #为找到的这些state/region的state项补上正确的值，从而去除掉state这一列的所有NaN
2. #思考：填充该需求中的空值可不可以使用fillna？
3.     # - 不可以。fillna可以使用空的紧邻值做填充。fillna(value='xxx')使用指定的值填充空值
4.     # 使用给元素赋值的方式进行填充！

复制代码

1. #1.先给USA的全称对应的空值进行批量赋值
2. abb_pop.loc[abb_pop['state/region'] == 'USA']#将usa对应的行数据取出
3. #1.2将USA对应的全称空对应的行索引取出
4. indexs = abb_pop.loc[abb_pop['state/region'] == 'USA'].index
6. abb_pop.iloc[indexs]
7. abb_pop.loc[indexs,'state'] = 'United States'
10. #2.可以将PR的全称进行赋值
11. abb_pop['state/region'] == 'PR'
12. abb_pop.loc[abb_pop['state/region'] == 'PR'] #PR对应的行数据
13. indexs = abb_pop.loc[abb_pop['state/region'] == 'PR'].index
15. abb_pop.loc[indexs,'state'] = 'PPPRRR'

复制代码

1. #合并各州面积数据areas
2. abb_pop_area = pd.merge(abb_pop,area,how='outer')

复制代码

1. #我们会发现area(sq.mi)这一列有缺失数据，找出是哪些行
2. abb_pop_area['area (sq. mi)'].isnull()
3. abb_pop_area.loc[abb_pop_area['area (sq. mi)'].isnull()] #空对应的行数据
4. indexs = abb_pop_area.loc[abb_pop_area['area (sq. mi)'].isnull()].index

复制代码

1. #找出2010年的全民人口数据(基于df做条件查询)
2. abb_pop_area.query('ages == "total" & year == 2010')

复制代码

1. #计算各州的人口密度(人口除以面积)
2. abb_pop_area['midu'] = abb_pop_area['population'] / abb_pop_area['area (sq. mi)']
3. abb_pop_area

复制代码

1. #排序，并找出人口密度最高的州
2. abb_pop_area.sort_values(by='midu',axis=0,ascending=False).iloc[0]['state']

复制代码

替换操作

• 替换操作可以同步作用于Series和DataFrame中
  
• 单值替换
  
  
  
  • 普通替换： 替换所有符合要求的元素:to_replace=15,value='e'
    
  • 按列指定单值替换： to_replace={列标签：替换值} value='value'
    
  
  
• 多值替换
  
  
  
  • 列表替换: to_replace=[] value=[]
    
  • 字典替换（推荐） to_replace={to_replace:value,to_replace:value}
    
  
  

我们要替换某列当中的数值

1. df.replace(to_replace={0，36},value='jiarui')
2. #将指定列的元素进行替换to_replase={列索引：被替换的值}

复制代码

映射操作

• 概念：创建一个映射关系列表，把values元素和一个特定的标签或者字符串绑定（给一个元素值提供不同的表现形式）
  
• 创建一个df，两列分别是姓名和薪资，然后给其名字起对应的英文名
  

1. dic = {
2.     'name':['regina','ivanlee','regina'],
3.     'salary':[15000,20000,15000]
4. }
5. df = DataFrame(data=dic)

复制代码

先指定给regina映射为zhangjiarui，首先建立一张映射关系表

1. #映射关系表
2. dic = {
3.     'regina':'zhangjiarui',
4.     'ivanlee':'liyifan'
5. }
6. df['e_name'] = df['name'].map(dic)

复制代码

map是Series的方法，只能被Series调用
运算工具

• 超过3000部分的钱缴纳50%的税，计算每个人的税后薪资
  1. #该函数是我们指定的一个运算法则
  2. def after_sal(s):#计算s对应的税后薪资
  3.     return s - (s-3000)*0.5
  4.    
  5. df['after_sal'] = df['salary'].map(after_sal)#可以将df['salary']这个Series中每一个元素（薪资）作为参数传递给s

  复制代码
  
  

排序实现的随机抽样

• take()
  
• np.random.permutation()
  

1. df = DataFrame(data=np.random.randint(0,100,size=(100,3)),columns=['A','B','C'])
3. #生成乱序的随机序列
4. np.random.permutation(10)
6. #将原始数据打乱
7. df.take([2,0,1],axis=1)
8. df.take(np.random.permutation(3),axis=1)

复制代码

数据的分类处理

• 数据分类处理的核心：
  
  
  
  • groupby()函数
    
  • groups属性查看分组情况
    
  
  

1. df = DataFrame({'item':['Apple','Banana','Orange','Banana','Orange','Apple'],
2.                 'price':[4,3,3,2.5,4,2],
3.                'color':['red','yellow','yellow','green','green','green'],
4.                'weight':[12,20,50,30,20,44]})

复制代码

1. #想要水果的种类进行分析
2. df.groupby(by='item')
4. <pandas.core.groupby.generic.DataFrameGroupBy object at 0x7fac66bd1b20>

复制代码

1. #查看详细的分组情况
2. df.groupby(by='item').groups

复制代码

• 分组聚合
  1. #计算出每一种水果的平均价格
  2. df.groupby(by='item')['price'].mean()
  4. out:
  5. item
  6. Apple     3.00
  7. Banana    2.75
  8. Orange    3.50
  9. Name: price, dtype: float64

  复制代码
  1. #计算每一种颜色对应水果的平均重量
  2. df.groupby(by='color')['weight'].mean()
  4. out:
  5. color
  6. green     31.333333
  7. red       12.000000
  8. yellow    35.000000
  9. Name: weight, dtype: float64

  复制代码
  1. dic = df.groupby(by='color')['weight'].mean().to_dict()
  2. #将计算出的平均重量汇总到源数据
  3. df['mean_w'] = df['color'].map(dic)

  复制代码
  
  

高级数据聚合

• 使用groupby分组后，也可以使用transform和apply提供自定义函数实现更多的运算
  
• df.groupby('item')['price'].sum()  df.groupby('item')['price'].apply(sum)
  
• transform和apply都会进行运算，在transform或者apply中传入函数即可
  
• transform和apply也可以传入一个lambda表达式
  

1. def my_mean(s):
2.     m_sum = 0
3.     for i in s:
4.         m_sum += i
5.     return m_sum / len(s)

复制代码

可以通过自定义的方式设计一个聚合操作

1. df.groupby(by='item')['price'].transform(my_mean) #经过映射
2. df.groupby(by='item')['price'].apply(my_mean) #不经过映射

复制代码

数据加载

• 读取type-.txt文件数据
  第一行被认成了列索引
  
• 将文件中每一个词作为元素存放在DataFrame中
  1. pd.read_csv('../data/type-.txt',header=None,sep='-') 原始的第一句话就不再是列索引

  复制代码
  
  
• 读取数据库中的数据
  1. #连接数据库，获取连接对象
  2. import sqlite3 as sqlite3
  3. conn = sqlite3.connect('../data/weather_2012.sqlite')
  4. #读取库表中的数据值
  5. sql_df=pd.read_sql('select * from weather_2012',conn)

  复制代码
  
  1. #将一个df中的数据值写入存储到db
  2. df.to_sql('sql_data456',conn)

  复制代码

透视表

• 透视表是一种可以对数据动态排布并且分类汇总的表格格式。或许大多数人都在Excel使用过数据透视表，也体会到它的强大功能，而在pandas中它被称作pivot_table。
  
• 透视表的优点：
  
  
  
  • 灵活性高，可以随意定制你的分析计算要求
    
  • 脉络清晰易于理解数据
    
  • 操作性强，报表神器
    
  
  

pivot_table有四个最重要的参数index、values、columns、aggfunc

• index参数：分类汇总的分类条件
  
  
  
  • 每个pivot_table必须拥有一个index。如果想查看对阵每个队伍的得分则需要对每一个队进行分类并计算其各类得分的平均值：
    
  
  
• 想看看对阵同一对手在不同主客场下的数据，分类条件为对手和主客场
  1. df.pivot_table(index=['对手','主客场'])

  复制代码
  
  
• values参数：需要对计算的数据进行筛选
  
  
  
  • 如果我们只需要在主客场和不同胜负情况下的得分、篮板与助攻三项数据：
    1. df.pivot_table(index=['主客场','胜负'],values=['得分','篮板','助攻'])

    复制代码
    
    
  
  
• Aggfunc参数：设置我们对数据聚合时进行的函数操作
  
  
  
  • 当我们未设置aggfunc时，它默认aggfunc='mean'计算均值。
    
  • 还想获得主客场和不同胜负情况下的总得分、总篮板、总助攻时：
    
  1. df.pivot_table(index=['主客场','胜负'],values=['得分','篮板','助攻'],aggfunc='sum')

  复制代码
  
  
  
  
• Columns:可以设置列层次字段
  
  
  
  • 对values字段进行分类
    
  1. #获取所有队主客场的总得分
  2. df.pivot_table(index='主客场',values='得分',aggfunc='sum')

  复制代码
  
  1. #获取每个队主客场的总得分（在总得分的基础上又进行了对手的分类）
  2. df.pivot_table(index='主客场',values='得分',columns='对手',aggfunc='sum',fill_value=none)

  复制代码
  
  
  

交叉表

• 是一种用于计算分组的特殊透视图,对数据进行汇总
  
• pd.crosstab(index,colums)
  
  
  
  • index:分组数据，交叉表的行索引
    
  • columns:交叉表的列索引
    
  
  

1. #求出不同性别的抽烟人数
2. pd.crosstab(df.smoke,df.sex)

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4