Package
drift_client.DriftDataPackage
¶
Parsed Drift Package with data payload
blob: bytes
property
¶
Serialized DriftPackage, can be passed to file write to save .dp file
Returns:
Type | Description |
---|---|
bytes
|
Serialized DriftPackage |
meta: Optional[MetaInfo]
property
¶
Meta information
Returns:
Type | Description |
---|---|
Optional[MetaInfo]
|
Meta information about the package |
package_id: int
property
¶
Package ID
Returns:
Type | Description |
---|---|
int
|
Package ID (by this all acquired data is synced) |
publish_timestamp: float
property
¶
Publish Timestamp
Returns:
Type | Description |
---|---|
float
|
Publish timestamp (Timestamp when the service has done its job and sends the output package.) |
source_timestamp: float
property
¶
Source Timestamp
Returns:
Type | Description |
---|---|
float
|
Source timestamp (Timestamp when the service has received the input package) |
status_code: int
property
¶
Status Code
Returns:
Type | Description |
---|---|
int
|
Status of the package. Ok (0) means the package is valid |
__init__(blob)
¶
Parsed Drift Package
Parameters:
Name | Type | Description | Default |
---|---|---|---|
blob |
bytes
|
Serialized package from database or stream |
required |
as_buffer()
¶
Data payload as Wavelet Buffer
Returns:
Type | Description |
---|---|
WaveletBuffer
|
Data payload as Wavelet Buffer |
as_np(scale_factor=0)
¶
Data payload as NumPy Array
Parameters:
Name | Type | Description | Default |
---|---|---|---|
scale_factor |
int
|
Wavelet composition factor, defaults to 0 |
0
|
Returns:
Type | Description |
---|---|
np.ndarray
|
Data payload as NumPy Array |
as_raw()
¶
Data payload as raw
Returns:
Type | Description |
---|---|
Optional[bytes]
|
Data payload as raw. None if no payload in the package |