Использование готовой коллекции данных в HistoryEmulationConnector

ок.

2017-04-26T13:55:56Z

ок.

Спасибо, что подсказали про смещение на 1 день. Вроде разобрался. Если период в HistoryMessageAdapte...

2017-04-26T02:58:00Z

Спасибо, что подсказали про смещение на 1 день. Вроде разобрался. Если период в HistoryMessageAdapter задавать в формате UTC, то пропущенных дней нет.

Период указываю следующим образом: [code]_historyConnector.HistoryMessageAdapter.StartDate = d1.Date.ToUniversalTime(); _historyConnector.HistoryMessageAdapter.StopDate = d2.Date.ToUniversalTime().AddDays(1);[/code]

Чисто логически можно предположить, что неделя на 1 день смещена... А как время в данных записано? К...

2017-04-25T13:16:24Z

Чисто логически можно предположить, что неделя на 1 день смещена... А как время в данных записано? Какое там смещение...

Я подгрузил с сайта Финам коллекцию тиковых сделок по акциям за период с 10.04.2017 по 21.04.2017 в ...

2017-04-24T14:49:55Z

Я подгрузил с сайта Финам коллекцию тиковых сделок по акциям за период с 10.04.2017 по 21.04.2017 в переменную _historyTicks, информация подгрузилась без ошибок за все даты (проверил). Далее в HistoryEmuationConnector передаю готовую коллекцию _historyTicks, как указано в ранее приложенном рабочем примере. После запуска коннектра, в функцию GetTrades, при вызове, поступают поочередно даты. За две пятницы дата в функцию не приходит (14.04.17 и 21.04.17). Очень странно поступают даты при вызове GetTrades: с начальной датой (10.04.17) функция вызывается три раза, далее приходят даты 11.04, 12.04, 13.04, 16.04 (воскресенье!?), 17.04, 18.04, 19.04, 20.04, через 15-20 секунд, вызывается повторно 19.04 и все. Акцию выбрал из топ списка - АЛРОСА (критерий ликвидность, и не очень много тиков).

Загружена куда?

2017-04-24T13:34:40Z

Загружена куда?

Спасибо. Все получилось, только не загружается информация за пятницы. Пробовал загружать историю (ти...

2017-04-24T02:57:42Z

Спасибо. Все получилось, только не загружается информация за пятницы. Пробовал загружать историю (тики) с Финама по акциям и передавать в HistoryEmulationConnector за период с 10.04.2017 по 21.04.2017 В метод GetTrades не приходят даты за пятницу 14.04.2017 и 21.04.2017. Проверил, история за эти даты с Финама была загружена.

Регистрацию источника нужно выполнять в событии NewSecurities.. Рабочий пример во вложении...

2017-04-17T12:48:00Z

Регистрацию источника нужно выполнять в событии NewSecurities.. Рабочий пример во вложении...

Нет еще..

2017-03-30T12:55:19Z

Нет еще..

Добрый день, прошло уже 2 недели, удалось ли проверить данную проблему?

2017-03-29T23:51:12Z

Добрый день, прошло уже 2 недели, удалось ли проверить данную проблему?

Хорошо, будем проверять..

2017-03-15T12:46:29Z

Хорошо, будем проверять..

Сделал все по Вашей рекомендации. Создал отдельный метод: public IEnumerable GetTrades(DateTimeOffse...

2017-03-15T02:04:33Z

Сделал все по Вашей рекомендации. Создал отдельный метод: public IEnumerable GetTrades(DateTimeOffset d) { var trades = _historyTicks.Where(ht => ((ht.ServerTime.Date == d.Date) && (ht.ServerTime.TimeOfDay == d.TimeOfDay))); return trades; }

Изменил: _historyConnector.RegisterHistorySource(_selSecurity, MarketDataTypes.Trades, null, GetTrades);

Поставил внутри метода GetTrades точку останова, но программа в него не заходит

Сделал дополнительную подписку на событие коннектора появления "нового сообщения" и вывод всех приходящих сообщений в окно Debug historyConnector.NewMessage += (m) => { var m1 = m; Debug.Print(m.ToString()); };

После вызова _historyConnector.Connect(); в переменную m приходит первое сообщение: Error,T(L)=0001/01/01 00:00:00.000,Error=Не найден подходящий адаптер для -8.

затем последовательно приходят следующие сообщения: Connect,T(L)=0001/01/01 00:00:00.000 Connect,T(L)=2017/03/13 09:59:42.000 PortfolioLookupResult,T(L)=2017/03/13 09:59:42.000,Orig=1 OrderStatus,T(L)=2017/03/13 09:59:42.000,Sec=S#:@, Native:,Type:,OriginTransId=0,TransId=2,OrderId=,TransId=2 PortfolioChange,T(L)=2017/03/13 09:59:42.000,T(S)=0001/01/01 00:00:00.000,P=test account,Changes=[RealizedPnL, 0],[VariationMargin, 0],[CurrentValue, 1000000],[BlockedValue, 0],[Commission, 0] Board,T(L)=2017/03/13 09:59:42.000,Code=TQBR,Ex=MOEX Security,T(L)=2017/03/13 09:59:42.000,Sec=S#:SBER@TQBR, Native:,Type: SecurityLookupResult,T(L)=2017/03/13 09:59:42.000,Orig=3 MarketData,T(L)=2017/03/13 09:59:42.000,Sec=S#:@, Native:,Type:,Sec=S#:@, Native:,Type:,Types=Level1,IsSubscribe=True,TransId=0,OrigId=4 Time,T(L)=2017/03/13 07:00:00.000,ID=0,Response= SecurityLookupResult,T(L)=2017/03/13 15:45:00.000,Orig=3 Time,T(L)=2017/03/13 15:45:00.000,ID=0,Response= Time,T(L)=2017/03/13 15:45:01.000,ID=0,Response= Time,T(L)=2017/03/13 15:45:02.000,ID=0,Response= Time,T(L)=2017/03/14 07:00:00.000,ID=0,Response= Time,T(L)=2017/03/14 15:45:00.000,ID=0,Response= Time,T(L)=2017/03/14 15:45:01.000,ID=0,Response= Time,T(L)=2017/03/14 15:45:02.000,ID=0,Response= PortfolioLookupResult,T(L)=2017/03/14 15:45:02.000,Orig=1 Disconnect,T(L)=2017/03/14 15:45:02.000 MarketData,T(L)=2017/03/14 15:45:02.000,Sec=S#:@, Native:,Type:,Sec=S#:@, Native:,Type:,Types=Level1,IsSubscribe=False,TransId=0,OrigId=5 Disconnect,T(L)=2017/03/14 18:49:49.000

Прилагаю файл сообщений Debug.

тики загружены в переменную _historyTicks по акциям SBER за период с 13.03.17 по 14.03.17, общее кол-во 105943 шт. дата первого тика d1= {13.03.2017 9:59:42 +03:00}, дата последнего тика d2={14.03.2017 18:49:49 +03:00}

Текст кода следующий:

    public IEnumerable<Message> GetTrades(DateTimeOffset d)
    {
        var trades = _historyTicks.Where(ht => ((ht.ServerTime.Date == d.Date) &&
                                                       (ht.ServerTime.TimeOfDay == d.TimeOfDay)));
        return trades;
    }

. . .

if (_historyTicks != null) {
d1 = _historyTicks.ElementAt(0).ServerTime; d2 = _historyTicks.ElementAt(_historyTicks.Count() - 1).ServerTime; }

                        _selSecurity = SecFinamBuilder.SelectedSecurityModyf;
                                                 
                        _selPortfolio = new Portfolio
                        {
                            Name = "test account",
                            BeginValue = 1000000,
                        };
                        
                        _historyConnector = new HistoryEmulationConnector(new[] {_selSecurity}, new[] {_selPortfolio})
                        {
                            EmulationAdapter =
                            {
                                Emulator = { Settings = { MatchOnTouch = false, } }
                            },

                            UseExternalCandleSource = false,
                            CreateDepthFromOrdersLog = false,
                            CreateTradesFromOrdersLog = false,
                        };

                        _historyConnector.HistoryMessageAdapter.StartDate = d1;
                        _historyConnector.HistoryMessageAdapter.StopDate = d2;
                                                   
                        _historyConnector.RegisterHistorySource(_selSecurity, MarketDataTypes.Trades, null, GetTrades);
                                                  
                        _historyConnector.NewMessage += (m) =>
                        {
                            var m1 = m;
                            Debug.Print(m.ToString());
                        };

                        _historyConnector.Connect();
                                                    
                        var candleManager = new CandleManager(_historyConnector);

                        LoadSettingsDiagram();

                        _candleTimeFrame = TimeSpan.FromMinutes(5);

                        _connectorCandleSеries = new CandleSeries(typeof(TimeFrameCandle), _selSecurity, _candleTimeFrame);

                        candleManager.Processing += DrawElement;

                        candleManager.Start(_connectorCandleSеries);

                        _historyConnector.Start();

[code]private IEnumerable> GetTrades(DateTimeOffset d) { var trades = _historyTicks.Where(ht => ((ht...

2017-03-14T13:00:22Z

[code]private IEnumerable> GetTrades(DateTimeOffset d) { var trades = _historyTicks.Where(ht => ((ht.ServerTime.Date == d.Date) && (ht.ServerTime.TimeOfDay==d.TimeOfDay))); return trades; }

_historyConnector.RegisterHistorySource(_selSecurity, MarketDataTypes.Trades, null, GetTrades);[/code]

Вот так сделайте... Поставьте точку останова внутрь GetTrades и посмотрите какое время приходит в функцию, и что она возвращает...

Добрый день. Хочу передать коллекцию тиковых сделок IEnumerable в HistoryEmulationConnector. Есть ли...

2017-03-14T01:41:52Z

Добрый день. Хочу передать коллекцию тиковых сделок IEnumerable в HistoryEmulationConnector.

Есть ли способ это сделать без использования механизма сохранения коллекции в файл через StorageRegistry?

Пытаюсь делать на основе примера тестирование на исторических данных через Финам, с использованием метода RegisterHistorySource, но никак не получается. Данные не подгружаются, свечки не строятся. Подскажите, пожалуйста, мою ошибку, может быть есть у кого рабочее решение.

Пытаюсь сделать следующим образом: _historyTicks - переменная содержащая коллекцию IEnumerable (тики загружены, проверил)

d1 = _historyTicks.ElementAt(0).ServerTime; d2 = _historyTicks.ElementAt(_historyTicks.Count() - 1).ServerTime;

_historyConnector = new HistoryEmulationConnector(new[] , new[] ) } },

                            UseExternalCandleSource = false,
                            CreateDepthFromOrdersLog = false,
                            CreateTradesFromOrdersLog = false,
                        };

_historyConnector.HistoryMessageAdapter.StartDate = d1; _historyConnector.HistoryMessageAdapter.StopDate = d2;

Func<DateTimeOffset, IEnumerable> selectionData = d => _historyTicks.Where(ht => ((ht.ServerTime.Date == d.Date) && (ht.ServerTime.TimeOfDay==d.TimeOfDay)));

_historyConnector.RegisterHistorySource(_selSecurity, MarketDataTypes.Trades, typeof (Trade), selectionData);

var candleManager = new CandleManager(_historyConnector);

_candleTimeFrame = TimeSpan.FromMinutes(5);

_connectorCandleSеries = new CandleSeries(typeof(TimeFrameCandle), _selSecurity, _candleTimeFrame);

candleManager.Processing += DrawElement;

candleManager.Start(_connectorCandleSеries);

_historyConnector.Start();