Skip to content

Commit 19b852d

Browse files
committed
ADD: Add DataFrame chunk reading
1 parent 2d40538 commit 19b852d

File tree

4 files changed

+347
-92
lines changed

4 files changed

+347
-92
lines changed

CHANGELOG.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
## 0.19.0 - TBD
44

55
#### Enhancements
6+
- Added `count` parameter to `DBNStore.to_df` and `DBNStore.to_ndarray` to help process large files incrementally
67
- Added the `Publisher`, `Venue`, and `Dataset` enums
78
- Replace null prices with `NaN` when `pretty_px=True` in `DBNStore.to_df()`
89
- Upgraded `databento-dbn` to 0.8.3
@@ -11,6 +12,9 @@
1112
- Fixed issue where exception messages were displaying JSON encoded data
1213
- Reduced floating error when converting prices to floats with `pretty_px=True`
1314

15+
#### Breaking changes
16+
- `DBNStore.to_df` now always utf-8 decodes string fields
17+
1418
## 0.18.1 - 2023-08-16
1519

1620
#### Bug fixes

databento/common/data.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,12 @@
1414
from databento.live import DBNRecord
1515

1616

17+
DEFINITION_TYPE_MAX_MAP = {
18+
x[0]: np.iinfo(x[1]).max
19+
for x in InstrumentDefMsg._dtypes
20+
if not isinstance(x[1], str)
21+
}
22+
1723
SCHEMA_STRUCT_MAP: dict[Schema, type[DBNRecord]] = {
1824
Schema.DEFINITION: InstrumentDefMsg,
1925
Schema.IMBALANCE: ImbalanceMsg,
@@ -51,12 +57,6 @@
5157
Schema.STATISTICS: StatMsg._dtypes,
5258
}
5359

54-
DEFINITION_TYPE_MAX_MAP = {
55-
x[0]: np.iinfo(x[1]).max
56-
for x in InstrumentDefMsg._dtypes
57-
if not isinstance(x[1], str)
58-
}
59-
6060
SCHEMA_COLUMNS = {
6161
Schema.MBO: MBOMsg._ordered_fields,
6262
Schema.MBP_1: MBP1Msg._ordered_fields,

0 commit comments

Comments
 (0)