假设您有三只股票,分别名为 S1、S2 和 S3,并且
每个都有一个数据框:
import pandas as pd
## create some fake data in format described by OP...
stock_names = ['S1', 'S2', 'S3']
df1 = pd.DataFrame({
'date': ['2019-05-05', '2019-05-06'],
'openp': [100, 110], 'highp': [115, 120],
'lowp': [100, 105], 'closep': [110, 120]
})
df2 = pd.DataFrame({
'date': ['2019-05-05', '2019-05-06'],
'openp': [110, 120], 'highp': [125, 130],
'lowp': [110, 115], 'closep': [120, 130]
})
df3 = pd.DataFrame({
'date': ['2019-05-05', '2019-05-06'],
'openp': [120, 130], 'highp': [135, 140],
'lowp': [120, 125], 'closep': [130, 140]
})
这里有几种存储数据的方法(包括 OP 提到的两种)。
## scenario 1: store the dfs in a list that you can iterate over
## (can only access stocks by index, not name)
df_list = [df1, df2, df3]
## scenario 2: dict of data frames -- just a better version of scenario 1
## (access a stock by its name, e.g. `df_dict['S1']`)
df_dict = dict(zip(stock_names, [df1, df2, df3]))
## scenario 3: single data frame, with 'stock' field to track where rows came from.
## (nice bc you can do grouped aggregations easily)
stacked_df = pd.concat(
[df.assign(stock = stock) for df, stock in zip(df_list, stock_names)])
根据我的经验,场景 3 通常(但不总是!)最好使用,
因为它与pd.DataFrame.groupby() 和pd.DataFrame.aggregate() 方法配合得很好。如果您在交互式外壳中进行探索性数据分析,则非常方便(另请参阅the pandas split-apply-combine user guide)。
这里有一个例子说明为什么场景 3 可以很好——直接同时计算每只股票的平均开盘价和收盘价(当然可以在其他场景中完成,只是不使用这种 groupby-aggregate 链)。
(stacked_df
.groupby(['stock'])
.aggregate({'openp': pd.np.mean, 'closep': pd.np.mean}))
## openp closep
## stock
## S1 105 115
## S2 115 125
## S3 125 135
您也可以使用其他感兴趣的聚合函数按多列分组,或按日期分组等。