Pandas ValueError: можно сравнивать только объекты Series с одинаковой меткой

df = pd.DataFrame([{'Instrument':'BHP', 'Date':'2012-04-18', 'Time':'09:59:34.160', 'Milliseconds':35974160 , 'RecordType':'ENTER', 'Value':36597.95},
                    {'Instrument':'BHP', 'Date':'2012-04-18', 'Time':'09:59:34.566', 'Milliseconds':35974566 , 'RecordType':'DELETE', 'Value':175.70},
                    {'Instrument':'BHP', 'Date':'2012-04-18', 'Time':'09:59:37.832', 'Milliseconds':35977832 , 'RecordType':'DELETE', 'Value':1093470.00},
                    {'Instrument':'BHP', 'Date':'2012-04-18', 'Time':'09:59:37.841', 'Milliseconds':35977841 , 'RecordType':'DELETE', 'Value':25799.34},
                    {'Instrument':'BHP', 'Date':'2012-04-18', 'Time':'09:59:38.846', 'Milliseconds':35978846 , 'RecordType':'ENTER', 'Value':2460.15},
                    {'Instrument':'BHP', 'Date':'2012-04-18', 'Time':'09:59:45.015', 'Milliseconds':35985015 , 'RecordType':'DELETE', 'Value':6731.00},
                    {'Instrument':'BHP', 'Date':'2012-04-18', 'Time':'09:59:47.024', 'Milliseconds':35987024 , 'RecordType':'OPEN', 'Value':np.nan}])```

У меня есть указанный выше DataFrame. Моя цель - получить сумму значений с помощью RecordType DELETE за 10 секунд до OPEN до OPEN. Я пробовал следующие коды:

opening_time = df[df.RecordType=='OPEN']
ten_seconds_before_open = opening_time['Milliseconds'] - 10*1000
delete_type = df[df.RecordType=='DELETE']
sum_delete = delete_type[delete_type.Milliseconds >= ten_seconds_before_open].Value.sum()
print(sum_delete)

Однако он возвращает ValueError: Can only compare identically-labeled Series objects. Могу я узнать, какое для этого лучшее решение?

Фактически, у меня есть миллионы строк, содержащих множество инструментов и дат. Я пытался кодировать, чтобы получить сумму значений DELETE для каждого инструмента для каждой даты,

def sum_delete_type(df):
     opening_time = df[df.RecordType=='OPEN']
     ten_seconds_before_open = opening_time['Milliseconds'] - 10*1000
     delete_type = df[df.RecordType=='DELETE']
     sum_delete = delete_type[delete_type.Milliseconds >= ten_seconds_before_open].Value.sum()
     return sum_delete

df.groupby(['Instrument', 'Date']).apply(sum_delete_type)

но это не сработало. Пожалуйста помоги. Спасибо.


pandas dataframe compare valueerror
person Shaun Lim    schedule 18.01.2020    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Как насчет этого

opening_time = df[df.RecordType=='OPEN']
ten_seconds_before_open = opening_time['Milliseconds'] - 10*1000
delete_type = df[df.RecordType=='DELETE']
y=[]
for x in ten_seconds_before_open:
    y.extend(delete_type[delete_type.Milliseconds >= x].index.tolist())
y=list(set(y))
delete_type[delete_type.index.isin(y)]['Milliseconds'].sum()
person Pei Li    schedule 18.01.2020