mirror of
https://github.com/c9s/bbgo.git
synced 2024-11-14 19:13:52 +00:00
42 lines
1019 B
Python
42 lines
1019 B
Python
from __future__ import annotations
|
|
|
|
from dataclasses import dataclass
|
|
from datetime import datetime
|
|
|
|
import bbgo_pb2
|
|
|
|
from ..utils import parse_float
|
|
from ..utils import parse_time
|
|
|
|
|
|
@dataclass
|
|
class KLine:
|
|
exchange: str
|
|
symbol: str
|
|
open: float
|
|
high: float
|
|
low: float
|
|
close: float
|
|
volume: float
|
|
session: str = None
|
|
start_time: datetime = None
|
|
end_time: datetime = None
|
|
quote_volume: float = None
|
|
closed: bool = None
|
|
|
|
@classmethod
|
|
def from_pb(cls, obj: bbgo_pb2.KLine) -> KLine:
|
|
return cls(
|
|
exchange=obj.exchange,
|
|
symbol=obj.symbol,
|
|
open=parse_float(obj.open),
|
|
high=parse_float(obj.high),
|
|
low=parse_float(obj.low),
|
|
close=parse_float(obj.close),
|
|
volume=parse_float(obj.volume),
|
|
quote_volume=parse_float(obj.quote_volume),
|
|
start_time=parse_time(obj.start_time),
|
|
end_time=parse_time(obj.end_time),
|
|
closed=obj.closed,
|
|
)
|