我创建了一个HDFStore.
HDFStore包含一个组df,它是一个包含2列的表.
第一列是字符串,第二列是DateTime(将按排序顺序).
已使用以下方法创建商店:
from numpy import ndarray
import random
import datetime
from pandas import DataFrame,HDFStore
def create(n):
mylist = ['A' * 4,'B' * 4,'C' * 4,'D' * 4]
data = []
for i in range(n):
data.append((random.choice(mylist),datetime.datetime.now() - datetime.timedelta(minutes=i)))
data_np = ndarray(len(data),dtype=[
('fac','U6'),('ts','datetime64[us]')])
data_np[:] = data
df = DataFrame(data_np)
return df
def create_patches(n,nn):
for i in range(n):
yield create(nn)
df = create_patches(100,1000000)
store = HDFStore('check.hd5')
for each in df:
store.append('df',each,index=False,data_columns=True,format = 'table')
store.close()
In [1]: %timeit store.select('df',['ts>Timestamp("2016-07-12 10:00:00")'])
1 loops,best of 3: 13.2 s per loop
所以,基本上这需要13.2秒,然后我用这个列添加了一个索引
In [2]: store.create_table_index('df',columns=['ts'],kind='full')
In [3]: %timeit store.select('df',best of 3: 12 s per loop
最佳答案
我认为当您指定data_columns = True时,您的列已被编入索引…
看这个演示:
In [39]: df = pd.DataFrame(np.random.randint(0,100,size=(10,3)),columns=list('ABC'))
In [40]: fn = 'c:/temp/x.h5'
In [41]: store = pd.HDFStore(fn)
In [42]: store.append('table_no_dc',df,format='table')
In [43]: store.append('table_dc',format='table',data_columns=True)
In [44]: store.append('table_dc_no_index',index=False)
未指定data_columns,因此仅索引索引:
In [45]: store.get_storer('table_no_dc').group.table
Out[45]:
/table_no_dc/table (Table(10,)) ''
description := {
"index": Int64Col(shape=(),dflt=0,pos=0),"values_block_0": Int32Col(shape=(3,),pos=1)}
byteorder := 'little'
chunkshape := (3276,)
autoindex := True
colindexes := {
"index": Index(6,medium,shuffle,zlib(1)).is_csi=False}
data_columns = True – 所有数据列都已编入索引:
In [46]: store.get_storer('table_dc').group.table
Out[46]:
/table_dc/table (Table(10,"A": Int32Col(shape=(),pos=1),"B": Int32Col(shape=(),pos=2),"C": Int32Col(shape=(),pos=3)}
byteorder := 'little'
chunkshape := (3276,)
autoindex := True
colindexes := {
"C": Index(6,zlib(1)).is_csi=False,"A": Index(6,"index": Index(6,"B": Index(6,zlib(1)).is_csi=False}
data_columns = True,index = False – 我们有数据列信息,但没有索引:
In [47]: store.get_storer('table_dc_no_index').group.table
Out[47]:
/table_dc_no_index/table (Table(10,)
colindexes – 显示上面示例中的索引列的列表