RangeConsolidator

QuantConnect.Data.Consolidators.RangeConsolidator

RangeConsolidator(
    range: int, selector: Any, volume_selector: Any = None
)

RangeConsolidator(
    range: int,
    selector: Callable[[IBaseData], float] = None,
    volume_selector: Callable[[IBaseData], float] = None,
)

Bases: BaseTimelessConsolidator[RangeBar]

This consolidator can transform a stream of IBaseData instances into a stream of RangeBar

Initializes a new instance of the RangeConsolidator class.

Parameters:

Name	Type	Description	Default
range	int	The Range interval sets the range in which the price moves, which in turn initiates the formation of a new bar.	required
selector	Any | Callable[[IBaseData], float]	Extracts the value from a data instance to be formed into a RangeBar. The default	None
volume_selector	Any | Callable[[IBaseData], float]	Extracts the volume from a data instance. The default value is null which does	None

current_bar

current_bar: RangeBar

Bar being created

This codeEntityType is protected.

range_size

range_size: float

Range for each RangeBar, this is, the difference between the High and Low for each RangeBar

range

range: int

Number of MinimumPriceVariation units

output_type

output_type: Type

Gets RangeBar which is the type emitted in the IDataConsolidator.data_consolidated event.

working_data

working_data: IBaseData

Gets a clone of the data being currently consolidated

consolidated

consolidated: IBaseData

Gets the most recently consolidated piece of data. This will be null if this consolidator has not produced any data yet.

input_type

input_type: Type

Gets the type consumed by this consolidator

data_consolidated

data_consolidated: _EventContainer[
    Callable[
        [
            Object,
            QuantConnect_Data_Consolidators_BaseTimelessConsolidator_T,
        ],
        Any,
    ],
    Any,
]

Event handler that fires when a new piece of data is produced

selector

selector: Callable[[IBaseData], float]

Extracts the value from a data instance to be formed into a T.

This codeEntityType is protected.

volume_selector

volume_selector: Callable[[IBaseData], float]

Extracts the volume from a data instance. The default value is null which does not aggregate volume per bar.

This codeEntityType is protected.

data_consolidated_handler

data_consolidated_handler: Callable[
    [Object, IBaseData], Any
]

Event handler type for the IDataConsolidator.DataConsolidated event

This codeEntityType is protected.

create_new_bar

create_new_bar(
    data: IBaseData, current_value: float, volume: float
) -> None

Creates a new bar with the given data

This codeEntityType is protected.

Parameters:

Name	Type	Description	Default
data	IBaseData	The new data for the bar	required
current_value	float	The new value for the bar	required
volume	float	The new volume for the bar	required

reset

reset() -> None

Resets the consolidator

update_bar

update_bar(
    time: Union[datetime, date],
    current_value: float,
    volume: float,
) -> None

Updates the current RangeBar being created with the given data. Additionally, if it's the case, it consolidates the current RangeBar

This codeEntityType is protected.

Parameters:

Name	Type	Description	Default
time	Union[datetime, date]	Time of the given data	required
current_value	float	Value of the given data	required
volume	float	Volume of the given data	required

scan

scan(current_local_time: Union[datetime, date]) -> None

Scans this consolidator to see if it should emit a bar due to time passing

Parameters:

Name	Type	Description	Default
current_local_time	Union[datetime, date]	The current time in the local time zone (same as BaseData.time)	required

update

update(data: IBaseData) -> None

Updates this consolidator with the specified data

Parameters:

Name	Type	Description	Default
data	IBaseData	The new data for the consolidator	required

dispose

dispose() -> None

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

on_data_consolidated

on_data_consolidated(
    consolidated: QuantConnect_Data_Consolidators_BaseTimelessConsolidator_T,
) -> None

Event invocator for the DataConsolidated event. This should be invoked by derived classes when they have consolidated a new piece of data.

This codeEntityType is protected.

Parameters:

Name	Type	Description	Default
consolidated	QuantConnect_Data_Consolidators_BaseTimelessConsolidator_T	The newly consolidated data	required