Pool
ABC Pool
Pool
Pool (_cnt:int=0)
*The abstract storage for pooling the real-time data from the cloud.
Pool provides the following features:
- load(): initialize the pool interface
- close(): destructor
- store(): Store the data in the pool
- delete(id): remove the data with id in the pool
- find(id): Get the data from the pool
- sample(size, query: Optional[dict]=None): Sample a batch of data from the pool
- count(query: Optional[dict] = None): Count the number of data in the pool
Attributes: - _type_T: the type of the data stored in the pool - _cnt: the number of records in the pool*
Pool.load
Pool.load ()
*Initialize the pool interface
This function should: - connect to db - init*
Pool.close
Pool.close ()
close the pool, for destructor
Pool.store
Pool.store (item:~ItemT)
Deposit an item (record) into the pool
Pool.delete
Pool.delete (idx)
delete an itme by id or name.
Pool._count
Pool._count (query:Optional[tspace.data.core.PoolQuery]=None)
*Count the number of records in the db.
query = { vehicle_id: str = “VB7”, driver_id: str = “longfei-zheng”, dt_start: datetime = None, dt_end: datetime = None, }*
Pool.find
Pool.find (query:tspace.data.core.PoolQuery)
Find an item by id or name.
Pool.sample
Pool.sample (size:int, query:Optional[tspace.data.core.PoolQuery]=None)
*Sample a size of records from the pool.
Args:
size: desired size of the samples
rule: an optional dictionary specifying a rule or a pipeline in mongodb
query: query to filter the records
vehicle_id: str = "VB7",
driver_id: str = "longfei-zheng",
dt_start: datetime = None,
dt_end: datetime = None,
}*
Type | Default | Details | |
---|---|---|---|
size | int | number of required samples | |
query | Optional[PoolQuery] | None | |
Returns | Optional[Union[pd.DataFrame, list[ItemT]]] | query to filter the records |
Pool.__iter__
Pool.__iter__ ()
Iterate over the pool.
Pool.__getitem__
Pool.__getitem__ (query:tspace.data.core.PoolQuery)
Get an item by id or name.
Pool.__len__
Pool.__len__ ()
Pool.__repr__
Pool.__repr__ ()
Return repr(self).