查看全课大纲(第 42 / 52 节)
- 1.量化分析基本概念:从咖啡馆到华尔街
- 2.量化交易员学习路线:从零基础到策略开发
- 3.量化策略生命周期:数据分析的五大流程
- 4.量化数据类型:数值型与类别型数据
- 5.量化沙盒搭建(1):Python与Anaconda安装
- 6.量化沙盒搭建(2):Jupyter Notebook与库配置
- 7.本地多源数据:量化历史回测的基石
- 8.TXT数据流操作:处理金融交易日志
- 9.JSON数据流操作:解析股票行情API响应
- 10.CSV行情文件操作:读取与存储历史K线
- 11.Excel报表操作:清洗财报与财务指标
- 12.量化数据库:SQL常用查询语法
- 13.量化数据库:Python连接与写入
- 14.量化多表连接:关联股票信息与行情
- 15.实战:小象咖啡店营业数据与个股财务指标的多源数据分析
- 16.量化数据采集:爬虫工作原理与合规
- 17.量化爬虫核心:URL管理与去重策略
- 18.量化网页下载:防反爬与请求头伪装
- 19.网页解析(1):使用XPath定位财经新闻
- 20.网页解析(2):使用CSS选择器与ItemLoader
- 21.Scrapy框架:构建工业级量化爬虫
- 22.Scrapy实战(1):新建项目与数据模型定义
- 23.Scrapy实战(2):编写财经爬虫逻辑
- 24.Scrapy实战(3):启用数据管道清洗行情
- 25.Scrapy实战(4):防反爬中间件配置
- 26.实战:构建每日热门个股行情自动采集系统
- 27.NumPy与SciPy:加速量化矩阵计算
- 28.NumPy数组:构建股票价格矩阵
- 29.数组切片:提取特定股票与交易日数据
- 30.NumPy常用方法:计算均值与波动率
- 31.向量化计算:摆脱缓慢的For循环
- 32.通用函数ufunc:计算对数收益率与累计收益
- 33.实战:股票组合资产收益率与协方差矩阵计算
- 34.Pandas Series:管理单只股票收盘价
- 35.Pandas DataFrame:构建多只股票行情面板
- 36.Pandas Index:时间序列索引与对齐
- 37.DataFrame索引操作:loc与iloc定位行情
- 38.索引总结:量化多字段筛选与定位
- 39.运算与对齐:合并不同交易日的数据
- 40.Pandas map:对股票代码与状态做映射
- 41.Pandas apply:滚动计算技术指标
- 42.排序操作:按市盈率与收益率对股票排名
- 43.数据清洗:填充与剔除停牌股票缺失值
- 44.数据清洗:剔除重复报价与异常交易数据
- 45.常用统计:量化最大回撤与分位数风险评估
- 46.极值定位:寻找历史最高价与最低价的发生日
- 47.风险与累计收益:计算年化波动率与累计回报
- 48.实战:小象咖啡店营业数据与热门个股时间序列清洗分析
- 49.Series索引操作:按位置与标签访问行情数据
- 50.文件读写操作:CSV行情数据导入导出
- 51.数据清洗:替换异常报价数据
- 52.常用统计:sum/mean/median/count聚合指标
排序操作:按市盈率与收益率对股票排名
约 10 分钟
小象实战讲义 · 量化交易Python入门:从咖啡馆到华尔街
Pandas 是量化交易员最核心的武器。本章你将通过 Series 和 DataFrame 深度处理时间序列行情数据,掌握 loc/iloc 定位筛选、缺失值与重复值清洗、以及最大回撤与年化波动率等核心指标统计计算。
💡 核心导读
本节将深入讲解 Pandas 中的排序操作,这是数据分析中最基础也最常用的数据整理技术。通过学习,您将掌握:
- 按单列/多列进行升序/降序排序
- 处理缺失值的排序策略
- 索引排序与重置索引的技巧
- 大型数据集排序的性能优化思路 我们将通过真实数据集演示如何通过排序快速发现数据规律,为后续分析打下坚实基础。
基本排序方法
按列值排序
import pandas as pd
data = {
'产品': ['手机', '笔记本', '平板', '耳机', '键盘'],
'销量': [120, 85, 90, 200, 65],
'单价': [5999, 8999, 3999, 399, 299]
}
df = pd.DataFrame(data)
df_sorted = df.sort_values('销量', ascending=False)
print(df_sorted)执行前数据:
产品 销量 单价
3 耳机 200 399
0 手机 120 5999
2 平板 90 3999
1 笔记本 85 8999
4 键盘 65 299执行后结果:
产品 销量 单价
3 耳机 200 399
0 手机 120 5999
2 平板 90 3999
1 笔记本 85 8999
4 键盘 65 299多列排序
import pandas as pd
data = {
'产品': ['手机', '笔记本', '平板', '耳机', '键盘'],
'销量': [120, 85, 90, 200, 65],
'单价': [5999, 8999, 3999, 399, 299]
}
df = pd.DataFrame(data)
df_multi_sorted = df.sort_values(['销量', '单价'], ascending=[False, True])
print(df_multi_sorted)产品 销量 单价
3 耳机 200 399
0 手机 120 5999
2 平板 90 3999
1 笔记本 85 8999
4 键盘 65 299索引排序
按索引排序
import pandas as pd
data = {
'产品': ['手机', '笔记本', '平板', '耳机', '键盘'],
'销量': [120, 85, 90, 200, 65],
'单价': [5999, 8999, 3999, 399, 299]
}
df = pd.DataFrame(data)
df_shuffled = df.sample(frac=1, random_state=42)
print("打乱后的索引:\n", df_shuffled.index)
df_reindexed = df_shuffled.sort_index()
print("\n按索引排序后:")
print(df_reindexed)打乱后的索引:
Index([1, 4, 2, 0, 3], dtype='int64')
按索引排序后:
产品 销量 单价
0 手机 120 5999
1 笔记本 85 8999
2 平板 90 3999
3 耳机 200 399
4 键盘 65 299重置索引
import pandas as pd
data = {
'产品': ['手机', '笔记本', '平板', '耳机', '键盘'],
'销量': [120, 85, 90, 200, 65],
'单价': [5999, 8999, 3999, 399, 299]
}
df = pd.DataFrame(data)
df_sorted = df.sort_values('销量', ascending=False)
df_reset = df_sorted.reset_index(drop=True)
print("重置索引后:")
print(df_reset)重置索引后:
产品 销量 单价
0 耳机 200 399
1 手机 120 5999
2 平板 90 3999
3 笔记本 85 8999
4 键盘 65 299高级排序技巧
处理缺失值
import pandas as pd
df_nan = pd.DataFrame({
'A': [1, None, 3, 2],
'B': ['x', 'y', None, 'z']
})
df_nan_sorted = df_nan.sort_values('A', na_position='last')
print(df_nan_sorted)A B
0 1.0 x
3 2.0 z
2 3.0 NaN
1 NaN y自定义排序规则
import pandas as pd
data = {
'产品': ['手机', '笔记本', '平板', '耳机', '键盘'],
'销量': [120, 85, 90, 200, 65],
'单价': [5999, 8999, 3999, 399, 299]
}
df = pd.DataFrame(data)
custom_order = ['耳机', '手机', '平板', '笔记本', '键盘']
df['产品'] = pd.Categorical(df['产品'], categories=custom_order, ordered=True)
df_custom_sorted = df.sort_values('产品')
print(df_custom_sorted)产品 销量 单价
3 耳机 200 399
0 手机 120 5999
2 平板 90 3999
1 笔记本 85 8999
4 键盘 65 299性能优化
对于大型数据集(>1GB)的排序:
import pandas as pd
import numpy as np
np.random.seed(42)
dates = pd.date_range('2023-01-01', periods=10, freq='D')
large_df = pd.DataFrame({
'timestamp': dates,
'price': np.random.uniform(100, 200, 10),
'volume': np.random.randint(1000, 10000, 10)
})
large_df_sorted = large_df.sort_values('timestamp', kind='mergesort')
print("稳定排序后:")
print(large_df_sorted)稳定排序后:
timestamp price volume
0 2023-01-01 137.454012 2685
1 2023-01-02 195.071431 1769
2 2023-01-03 173.199394 7949
3 2023-01-04 159.865848 3433
4 2023-01-05 115.601864 6311
5 2023-01-06 115.599452 6051
6 2023-01-07 105.808361 7420
7 2023-01-08 186.617615 2184
8 2023-01-09 160.111501 5555
9 2023-01-10 170.807258 4385📝 动手练一练
第 1 题 · 概念应用
你正在构建一个“双因子”股票筛选策略,希望从股票池中优先选择估值较低且近期动量较强的股票。你决定使用市盈率(pe_ratio)和最近一个月的收益率(monthly_return)作为排序依据。
以下哪段代码能正确实现“先按市盈率升序(低估值优先),若市盈率相同,则按月度收益率降序(高动量优先)”的排序逻辑?
A.
df_sorted = df.sort_values(by=['pe_ratio', 'monthly_return'], ascending=[True, True])B.
df_sorted = df.sort_values(by=['monthly_return', 'pe_ratio'], ascending=[False, True])C.
df_sorted = df.sort_values(by=['pe_ratio', 'monthly_return'], ascending=[True, False])D.
df_sorted = df.sort_values(by=['pe_ratio', 'monthly_return'], ascending=[False, True])👉 点击查看参考答案
答案:C
推理过程: sort_values 的 by 参数列表定义了排序的优先级顺序。ascending 列表则对位指定每个排序字段是升序(True)还是降序(False)。
- 要求“先按市盈率升序”,对应
by[0]='pe_ratio'且ascending[0]=True。 - 要求“若市盈率相同,则按月度收益率降序”,对应
by[1]='monthly_return'且ascending[1]=False。 因此,选项 C 的ascending=[True, False]组合完全符合题意。
选项 A 对收益率也用了升序,会优先选动量弱的股票,不符合“高动量优先”。 选项 B 改变了排序优先级,变成了先按收益率排序,不符合“先按市盈率”的要求。 选项 D 对市盈率用了降序,会优先选高估值股票,不符合“低估值优先”。
第 2 题 · 代码填空
在分析股票行情数据时,你发现数据集的索引是乱序的日期字符串(如 ‘2023-10-26’)。为了进行时间序列分析,你需要先将数据按日期索引进行升序排列,并重置为从0开始的连续整数索引。
请补全以下代码,实现上述两步操作:
import pandas as pd
# 模拟一个索引乱序的行情数据
data = {
'close': [150.2, 152.5, 149.8, 151.0, 153.3]
}
index_values = ['2023-10-26', '2023-10-24', '2023-10-25', '2023-10-23', '2023-10-27']
df = pd.DataFrame(data, index=index_values)
print("原始数据(索引乱序):")
print(df)
# 第一步:按索引(日期)进行升序排序
df_sorted = df.______(ascending=True)
# 第二步:重置索引,丢弃旧的日期索引,生成新的连续整数索引
df_final = df_sorted.reset_index(drop=True)
print("\n处理后的数据:")
print(df_final)👉 点击查看参考答案
空位应填:sort_index
补全后的完整可运行代码:
import pandas as pd
# 模拟一个索引乱序的行情数据
data = {
'close': [150.2, 152.5, 149.8, 151.0, 153.3]
}
index_values = ['2023-10-26', '2023-10-24', '2023-10-25', '2023-10-23', '2023-10-27']
df = pd.DataFrame(data, index=index_values)
print("原始数据(索引乱序):")
print(df)
# 第一步:按索引(日期)进行升序排序
df_sorted = df.sort_index(ascending=True)
# 第二步:重置索引,丢弃旧的日期索引,生成新的连续整数索引
df_final = df_sorted.reset_index(drop=True)
print("\n处理后的数据:")
print(df_final)运行结果:
原始数据(索引乱序):
close
2023-10-26 150.2
2023-10-24 152.5
2023-10-25 149.8
2023-10-23 151.0
2023-10-27 153.3
处理后的数据:
close
0 151.0
1 152.5
2 149.8
3 150.2
4 153.3解释:
df.sort_index(ascending=True)根据索引值(日期字符串)进行升序排列。字符串格式的日期按字典序排序,恰好与时间顺序一致。df_sorted.reset_index(drop=True)将排序后的 DataFrame 的索引重置为从0开始的连续整数。参数drop=True表示丢弃原来的日期索引,不将其保留为新的一列。
本章小结
📋 行动清单
- 使用本地销售数据,分别按销售额和利润率进行多列排序,观察数据分布特征
- 创建一个含缺失值的DataFrame,测试不同na_position参数对排序结果的影响
- 对超过100万行的数据集测试quicksort、mergesort和heapsort的性能差异
—— 小象教研组