Очень похоже на этот вопрос, за исключением того, что мне нужно учитывать как дату, так и время; indexer_between_time, похоже, не поддерживает какие-либо форматы даты и времени, которые я могу найти.
У меня есть фрейм данных dask, который выглядит так:
logger_volt lat lon
time
2017-01-01 00:01:20 12.0112 37.150902 -98.362
2017-01-01 00:01:40 12.0113 37.150902 -98.362
2017-01-01 00:02:00 12.0057 37.150902 -98.362
2017-01-01 00:02:20 12.0113 37.150902 -98.362
2017-01-01 00:02:40 12.0058 37.150902 -98.362
2017-01-01 00:03:00 12.0113 37.150902 -98.362
И список столбцов, которые нужно замаскировать в определенных временных диапазонах (данные в этих диапазонах считаются «плохими» и вместо этого должны возвращать None) в форме или списке кортежей Python:
[ # var start of mask end of mask
('lat', '2017-01-01 00:01:40', '2017-01-01 00:02:00'),
('lon', '2017-01-01 00:02:40', '2017-01-01 00:03:00'),
]
logger_volt lat lon
time
2017-01-01 00:01:20 12.0112 37.150902 -98.362
2017-01-01 00:01:40 12.0113 None -98.362
2017-01-01 00:02:00 12.0057 None -98.362
2017-01-01 00:02:20 12.0113 37.150902 -98.362
2017-01-01 00:02:40 12.0058 37.150902 None
2017-01-01 00:03:00 12.0113 37.150902 None
dqrs = [ # var start of mask end of mask
('lat', '2017-01-01 00:01:40', '2017-01-01 00:02:00'),
('lon', '2017-01-01 00:02:40', '2017-01-01 00:03:00'),
]
df = xarray.open_dataset('filename.cdf').to_dask_dataframe()
dqr_mask = (df == df) | df.isnull() # create a dummy mask that's all True
for var, start, end in dqrs:
dqr_mask |= ((df.columns == var) & (df.index >= start) & (df.index >= end))
df = df.mask(dqr_mask).compute()
df[start:end] = None для этого не сработает.





Вам нужно выбрать только столбец var из dqr_mask в цикле for, который вы хотите изменить. вот один способ:
dqr_mask = df != df # you want a mask set to False where there is a value
for var, start, end in dqrs:
#set to True the column var when index is between start and end
dqr_mask[var] |= (df.index >= start) & (df.index <= end)
# where dqr_mask False it keeps df otherwise it set the value to None
df = df.mask(dqr_mask,other=None)
print (df)
logger_volt lat lon
time
2017-01-01 00:01:20 12.0112 37.1509 -98.362
2017-01-01 00:01:40 12.0113 None -98.362
2017-01-01 00:02:00 12.0057 None -98.362
2017-01-01 00:02:20 12.0113 37.1509 -98.362
2017-01-01 00:02:40 12.0058 37.1509 None
2017-01-01 00:03:00 12.0113 37.1509 None