我有以下数据帧,它有大约4000个报价器,总共大约有200万行:
Ticker Date Rank
1 01/01/2000 5
1 01/02/2000 NaN
2 01/01/2000 4
2 01/02/2000 2 我现在运行以下代码来继续Rank列,它工作得很好:
import pandas as pd
df= df.sort_values(by=["Ticker", "Date"], ascending=[True,True])
df['Rank'] = df.groupby('Ticker')['Rank'].fillna(value=None, method="ffill")然而,我现在想继续写一个不同的专栏。为了创建这个列,我执行以下操作:
import numpy as np
df["Code"]=np.NaN在这个函数中,我写了一些代码,根据df "add“中的日期和滚动条值,大约200个值将被1替换。这段代码的工作方式如下所示:
df["Code"][(df.Date == add) & (df["Ticker"] == column)] = 1这使得我的数据帧看起来像这样:
Ticker Date Rank Code
1 01/01/2000 5 NaN
1 01/02/2000 NaN NaN
2 01/01/2000 4 1
2 01/02/2000 2 NaN现在,我想继续阅读这一列,但是代码永远需要花费时间。
import pandas as pd
df= df.sort_values(by=["Ticker", "Date"], ascending=[True,True])
df['Code'] = df.groupby('Ticker')['Code'].fillna(value=None, method="ffill")我已经运行了两天,我的电脑崩溃了。我做事情的方式肯定有一些错误,因为上面的carryforward运行得太快了,而这个甚至都没有完成。我检查了"Code“的数据类型,它是float64。
有人能帮上忙吗?
发布于 2017-06-27 15:24:58
我尝试使用sort=False to groupby和DataFrameGroupBy.ffill来改进您的代码
#convert column to datetime
df["Date"] = pd.to_datetime(df["Date"])
#ascending can be omit, because default value
df= df.sort_values(by=["Ticker", "Date"])
df['Rank'] = df.groupby('Ticker', sort=False)['Rank'].ffill()
add = '01/01/2000'
column = 2
df.loc[(df.Date == add) & (df["Ticker"] == column), "Code"] = 1
#sorting again is not necessary
df['Code'] = df.groupby('Ticker', sort=False)['Code'].ffill()
print (df)
Ticker Date Rank Code
0 1 2000-01-01 5.0 NaN
1 1 2000-01-02 5.0 NaN
2 2 2000-01-01 4.0 1.0
3 2 2000-01-02 2.0 1.0https://stackoverflow.com/questions/44774376
复制相似问题