Documentation discussion algorithm-reference/consolidating-data

Hello,

I am new to QuantConnect.  I was wondering if there is a way to develope our custom Consolidators? (Sorry if the solution is so obvious, I tried to scan through the whole docs but cant figure out the solution.)

For example, I have tick data from some exchanges, apart from the standard 'price' and 'volume' information. There is also an additional field indicating the agressive side of the trade (taker buy or taker sell).  I assume that current implemented TickConsolidator will return Time | Open | High | Low | Close | Volume. Is there any way we can include an additional field using the taker side information. For example Total Taker Buy Volume during the aggregated time?

Thanks,

HP

Hi, just noticed your question as I came here looking for some insights to troubleshoot fillForward for quoteBars as I also customized my tickProcessing. Anyways,
(1) For backtesting, you can download a ts-indexed python df you show up there. Utilize data by df.loc[<TimeStamp from OnData()]>] such as Time(). That's how I backtest with precomputed data in QC.
(2) Obviously, for live trading/processing, you'd need another solution.
(3) Regarding this:
volume_pos = data_df.volume.apply(lambda x: x if x >0 else 0).sum() # only take trade volume resulted from a taker buy order
Not sure how the Bitfinex Brokerage is setup these, but volume is potentially never negative. And regarding 'only take trade' - well, two makers cant be matched. There's always 1 side that's taking. Perhaps you wanna differentiate Buy vs. Sell rather? Such as PlusTick, MinusTick, ZeroPlusTick, ZeroMinusTick.... That has some insights when analyzed...

 

Hi hieppham please start a new thread with an example algorithm attached.

Thanks Jared. I started a new thread with an example algorithm here

Is there are defintion anywhere of what is a consolidator?

Hi Johnny Cash ,

Please check out the documentation, under Consolidating Data, to learn all about it.