EstimizeConsensusDataPoint
QuantConnect.DataSource.EstimizeConsensusDataPoint
EstimizeConsensusDataPoint()
EstimizeConsensusDataPoint(csv_line: str)
Bases: BaseData
A single consensus of a release, for one source (Wall Street or Estimize) and one metric (EPS or Revenue). Estimize publishes several of these for the same instant, so they are delivered to algorithms grouped in an EstimizeConsensus.
Signature descriptions:
-
Empty constructor required for successful Json.NET deserialization
-
Creates an instance from CSV lines
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
csv_line
|
Optional[str]
|
CSV file |
None
|
id
id: str
The unique identifier for the estimate
mean
mean: Optional[float]
The mean of the distribution of estimates (the "consensus")
value
value: float
The mean of the distribution of estimates (the "consensus")
high
high: Optional[float]
The highest estimate in the distribution
low
low: Optional[float]
The lowest estimate in the distribution
standard_deviation
standard_deviation: Optional[float]
The standard deviation of the distribution
count
count: Optional[int]
The number of estimates in the distribution
updated_at
updated_at: datetime
The timestamp of this consensus (UTC)
fiscal_year
fiscal_year: Optional[int]
The fiscal year for the release
fiscal_quarter
fiscal_quarter: Optional[int]
The fiscal quarter for the release
end_time
end_time: datetime
The timestamp of this consensus (UTC)
data_type
data_type: MarketDataType
Market Data Type of this data - does it come in individual price packets or is it grouped into OHLC.
time
time: datetime
Current time marker of this data packet.
price
price: float
As this is a backtesting platform we'll provide an alias of value as price.
ALL_RESOLUTIONS
ALL_RESOLUTIONS: List[Resolution] = ...
A list of all Resolution
This Field is protected.
DAILY_RESOLUTION
DAILY_RESOLUTION: List[Resolution] = ...
A list of Resolution.DAILY
This Field is protected.
MINUTE_RESOLUTION
MINUTE_RESOLUTION: List[Resolution] = ...
A list of Resolution.MINUTE
This Field is protected.
HIGH_RESOLUTION
HIGH_RESOLUTION: List[Resolution] = ...
A list of high Resolution, including minute, second, and tick.
This Field is protected.
OPTION_RESOLUTIONS
OPTION_RESOLUTIONS: List[Resolution] = ...
A list of resolutions support by Options
This Field is protected.
is_fill_forward
is_fill_forward: bool
True if this is a fill forward piece of data
data_time_zone
data_time_zone() -> Any
Specifies the data time zone for this data type. This is useful for custom data types
Returns:
| Type | Description |
|---|---|
Any
|
The DateTimeZone of this data type. |
is_sparse_data
is_sparse_data() -> bool
Indicates whether the data is sparse.
Returns:
| Type | Description |
|---|---|
bool
|
true. |
reader
reader(
config: SubscriptionDataConfig,
line: str,
date: datetime,
is_live_mode: bool,
) -> BaseData
Reader converts each line of the data source into BaseData objects.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
config
|
SubscriptionDataConfig
|
Subscription data config setup object |
required |
line
|
str
|
Content of the source document |
required |
date
|
datetime
|
Date of the requested data |
required |
is_live_mode
|
bool
|
true if we're in live mode, false for backtesting mode |
required |
Returns:
| Type | Description |
|---|---|
BaseData
|
Estimize consensus object. |
requires_mapping
requires_mapping() -> bool
Indicates if there is support for mapping
Returns:
| Type | Description |
|---|---|
bool
|
True indicates mapping should be used. |
to_string
to_string() -> str
Formats a string with the Estimize Consensus information.
clone
Return a new instance clone of this object, used in fill forward
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
fill_forward
|
Optional[bool]
|
True if this is a fill forward clone |
None
|
Returns:
| Type | Description |
|---|---|
BaseData
|
A clone of the current object. |
default_resolution
default_resolution() -> Resolution
Gets the default resolution for this data and security type
deserialize_message
deserialize_message(serialized: str) -> Sequence[BaseData]
Deserialize the message from the data server
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
serialized
|
str
|
The data server's message |
required |
Returns:
| Type | Description |
|---|---|
Sequence[BaseData]
|
An enumerable of base data, if unsuccessful, returns an empty enumerable. |
get_source
get_source(
config: SubscriptionDataConfig,
date: datetime,
is_live_mode: bool,
) -> SubscriptionDataSource
Return the URL string source of the file. This will be converted to a stream
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
config
|
SubscriptionDataConfig
|
Configuration object |
required |
date
|
datetime
|
Date of this source file |
required |
is_live_mode
|
bool
|
true if we're in live mode, false for backtesting mode |
required |
Returns:
| Type | Description |
|---|---|
SubscriptionDataSource
|
String URL of source file. |
should_cache_to_security
should_cache_to_security() -> bool
Indicates whether this contains data that should be stored in the security cache
Returns:
| Type | Description |
|---|---|
bool
|
Whether this contains data that should be stored in the security cache. |
supported_resolutions
supported_resolutions() -> List[Resolution]
Gets the supported resolution for this data and security type
update
update(
last_trade: float,
bid_price: float,
ask_price: float,
volume: float,
bid_size: float,
ask_size: float,
) -> None
Update routine to build a bar/tick from a data update.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
last_trade
|
float
|
The last trade price |
required |
bid_price
|
float
|
Current bid price |
required |
ask_price
|
float
|
Current asking price |
required |
volume
|
float
|
Volume of this trade |
required |
bid_size
|
float
|
The size of the current bid, if available |
required |
ask_size
|
float
|
The size of the current ask, if available |
required |
update_ask
update_ask(ask_price: float, ask_size: float) -> None
Updates this base data with the new quote ask information
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
ask_price
|
float
|
The current ask price |
required |
ask_size
|
float
|
The current ask size |
required |
update_bid
update_bid(bid_price: float, bid_size: float) -> None
Updates this base data with the new quote bid information
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
bid_price
|
float
|
The current bid price |
required |
bid_size
|
float
|
The current bid size |
required |
update_quote
update_quote(
bid_price: float,
bid_size: float,
ask_price: float,
ask_size: float,
) -> None
Updates this base data with new quote information
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
bid_price
|
float
|
The current bid price |
required |
bid_size
|
float
|
The current bid size |
required |
ask_price
|
float
|
The current ask price |
required |
ask_size
|
float
|
The current ask size |
required |
update_trade
update_trade(last_trade: float, trade_size: float) -> None
Updates this base data with a new trade
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
last_trade
|
float
|
The price of the last trade |
required |
trade_size
|
float
|
The quantity traded |
required |