コンテンツにスキップ

DataStore.to_parquet

Python

レコードを Parquet として書き出します。既定の設定なら、サービスが返したファイルそのものになります。

パラメーター

path str | Path 必須

書き出す先。

price_type str 任意 = "float"

"float"、"fixed"、"decimal" のいずれか。to_df と同じです。

pretty_ts bool 任意 = True

タイムスタンプ型で書き出します。False にすると UTC ナノ秒になります。

map_symbols bool 任意 = True

symbol 列を残します。

戻り値

Path

書き出したパス。

API メソッド
DataStore.to_parquet(
    path: str | Path,
    price_type: str = "float",
    pretty_ts: bool = True,
    map_symbols: bool = True,
) -> Path
使用例
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
import briskapi

client = briskapi.Historical()
data = client.timeseries.get_range(
    dataset="XTKS.BRISKDEMO",
    symbols=["7203"],
    schema="trades",
    start="2021-09-27T09:00",
    end="2021-09-27T09:00:05",
)
import pyarrow.parquet as pq

data.to_parquet("trades.parquet")
print(pq.read_schema("trades.parquet"))
レスポンス例デモで実行した結果
ts_recv: timestamp[ns, tz=UTC]
ts_event: timestamp[ns, tz=UTC]
publisher_id: uint16
instrument_id: uint32
action: string
side: string
depth: uint8
price: double
size: uint64
flags: uint8
sequence: uint64
trade_id: string
symbol: string