Построение свечей из хранимых тиков в версии 4.3.25.2

К сожалению, опять не сходится. Посмотрите сами на разницу в описанной мной проблеме и на Ваше объяс...

2017-11-17T18:36:47Z

К сожалению, опять не сходится.
Посмотрите сами на разницу в описанной мной проблеме и на Ваше объяснение.
Вот мой пример из поста выше:

Quote:

например, срабатывает правило CandleManager.WhenCandlesFinished при закрытии свечи с 10 до 11 часов, а после этого еще продолжают срабатывать правила Security.WhenNewTrade с тиками с 10 до 11 часов. Причем такая расснихронизация по хранимым тикам может достигать нескольких дней. Срабатывает правило завершения свечи где-нибудь в середине дня 03.08.2017, а в это время еще продолжают срабатывать правила новых сделок за 02.08.2017.

А вот Ваш пояснение:

Quote:

Например, в середине дня вы запускаете построение свечей с начала дня. Конечно же в самом начале свечи будут идти со временем на несколько часов меньше, чем тещие тики в Security.WhenNewTrade

Заметьте, что все с точностью до наоборот. Запаздывают не свечи, как Вы пишите, а запаздывают сделки. Причем все это только при построении на основе данных тиков, которые только хранятся. Никакого отношения к текущему дню проблема не имеет. То есть если сегодня 17.11, то при загрузке данных, например, за 13.11 правила завершения свечей за 13.11 срабатывают гораздо быстрее, чем правила поступление новой сделки за то же самое 13.11.

Коллеги, ну как же так. Вы хотя бы посмотрите внимательно мое первоначальное сообщение об ошибке (н...

2017-11-16T11:53:57Z

Evgeny

Да, именно это и было в нашем ответе. Рассинхронизация идет из-за истории. Она может быть получена и в реальном времени, и считана с диска. Например, в середине дня вы запускаете построение свечей с начала дня. Конечно же в самом начале свечи будут идти со временем на несколько часов меньше, чем тещие тики в Security.WhenNewTrade. Затем данные синхронизуются.

Ваш измененный пример строит свечи из истории + реальных данных. В Security.WhenNewTrade только реал...

2017-11-15T19:26:46Z

Support

Ваш измененный пример строит свечи из истории + реальных данных. В Security.WhenNewTrade только реальные. Поэтому это разные потоки данных.

Коллеги, ну как же так. Вы хотя бы посмотрите внимательно мое первоначальное сообщение об ошибке (не говоря уже о том, чтобы его воспроизвести самостоятельно по тому примеру, который я прислал). Я же сразу написал, что проблема возникает пока свечи строятся из хранимых тиков. То есть рассинхронизация построенных свечей из хранимых тиков с событием Security.WhenNewTrade, сгенерированным на основе тех же хранимых тиков. Когда все выходит в онлайн - все нормализуется и рассинхронизации не возникает.

Вы могли сразу мне ответить, что не считаете описанный мной случай ошибкой и все. Вместо этого Вы в третьем сообщении придумываете причину, почему не считаете это ошибкой, которая к моему примеру не имеет никакого отношения.

Ваш измененный пример строит свечи из истории + реальных данных. В Security.WhenNewTrade только реал...

2017-11-15T13:20:09Z

Причем тут обновление инструмента? Судя по коду правило Security.WhenNewTrade срабатывает при появле...

2017-11-14T19:22:19Z

Причем тут обновление инструмента?
Судя по коду правило Security.WhenNewTrade срабатывает при появлении новой тиковой сделки (то есть того же самого источника данных, что и при построении свечей), либо при включенном параметре CreateTradesFromOrdersLog (в моем случае он отключен).

То есть рассинхронизация происходит не между разными потоками данных, а в рамках одного и того же потока данных.
Вы также не считаете это ошибкой?

Свечи строятся в вашем случае из тиков хранилища + поступающих из Квик. Инструмент обновляется тольк...

2017-11-14T17:21:45Z

Свечи строятся в вашем случае из тиков хранилища + поступающих из Квик.

Инструмент обновляется только по таблице текущих параметров.

>>>Свечи в вашем случае сначала получаются готовые, затем обновляются тиковыми данными. Это не так. ...

2017-11-14T13:21:32Z

>>>Свечи в вашем случае сначала получаются готовые, затем обновляются тиковыми данными.

Это не так. У меня все свечи, в том числе исторические, строятся из тиков. В хранилище свечей вообще нет.

>>>Инструмент обновляется только тиковыми данными.

Ответьте, пожалуйста, на вторую часть предыдущего вопроса: на основе какого потока данных срабатывает правило Security.WhenNewTrade ? На основе обновления инструмента или на основе данных тиковых сделок?

И еще: под обновлением инструмента Вы понимаете подписку Connector.RegisterSecurity() ?

Свечи в вашем случае сначала получаются готовые, затем обновляются тиковыми данными. Инструмент обно...

2017-11-14T12:35:14Z

Свечи в вашем случае сначала получаются готовые, затем обновляются тиковыми данными. Инструмент обновляется только тиковыми данными.

Скажите, пожалуйста: 1. Из какого потока данных создаются в моем случае свечи? 2. На основе какого п...

2017-11-13T19:22:52Z

Скажите, пожалуйста:
1. Из какого потока данных создаются в моем случае свечи?
2. На основе какого потока данных срабатывает в моем случае правило Security.WhenNewTrade ?
Спасибо.

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

2017-11-13T13:15:18Z

Добрый день,

Свечи строится в вашем случае из локальных данных и потока сделок. Инструмент же обновляется только из потока сделок. Синхронизации между двумя этими действиями нет. Это необхожимо делать в программе.

Пока не было времени. Задача стоит в списке.

2017-09-14T17:26:53Z

Пока не было времени. Задача стоит в списке.

Коллеги, подскажите, пожалуйста, по описанной выше проблеме рассинхронизации поступающих данных тико...

2017-09-13T19:49:32Z

Коллеги, подскажите, пожалуйста, по описанной выше проблеме рассинхронизации поступающих данных тиков и свечей (при их построении из тиков) - вы считаете это ошибкой, которая будет исправлена? Или все-таки теперь необходимо самостоятельно в каждой стратегии заботиться о синхронизации этих данных?

Да, могу. В аттаче доработанный исходный код для примера SampleQuikCandles. Соответственно этим файл...

2017-08-08T19:30:34Z

Да, могу.
В аттаче доработанный исходный код для примера SampleQuikCandles. Соответственно этим файлом нужно заменить аналогичный в папке с этим примером.
Для воспроизведения в строках 120 и 121 нужно заменить пути к папкам с хранилищем EntityRegistry и StorageRegistry на Ваши.
Я тестировал на часовых данных SBER@TQBR.
Воспроизвести можно так:
1. Поставить точку прерывания на срабатывание правила WhenCandlesFinished (строка 215)
2. После того, как точка прерывания сработает, запомнить время окончания свечи, которая пришла, и поставить точку прерывания на срабатывание правила WhenNewTrade (строка 211).
3. После того как правило WhenNewTrade сработает, убедиться, что время пришедшей сделки меньше времени пришедшей ранее свечи.

Могли бы вы прислать пример для воспроизведения ошибки?

2017-08-08T10:59:48Z

Могли бы вы прислать пример для воспроизведения ошибки?

Обновился до версии 4.3.26. Проблема со склеиванием свечей из хранимых тиков и онлайн тиков исчезла....

2017-08-07T23:26:07Z

Обновился до версии 4.3.26.
Проблема со склеиванием свечей из хранимых тиков и онлайн тиков исчезла. То есть свечи стали строиться.
Однако я заметил, что теперь, пока свечи строятся из хранимых тиков, возникает рассинхронизация в поступающих данных по правилу CandleManager.WhenCandlesFinished и по правилу Security.WhenNewTrade. То есть, например, срабатывает правило CandleManager.WhenCandlesFinished при закрытии свечи с 10 до 11 часов, а после этого еще продолжают срабатывать правила Security.WhenNewTrade с тиками с 10 до 11 часов. Причем такая расснихронизация по хранимым тикам может достигать нескольких дней. Срабатывает правило завершения свечи где-нибудь в середине дня 03.08.2017, а в это время еще продолжают срабатывать правила новых сделок за 02.08.2017.
Раньше такого не было.
По поступающим онлайн тикам и сейчас такого не наблюдается.
Скажите, пожалуйста, такая рассинхронизация поступающих данных - это какая-то ошибка или теперь нельзя рассчитывать на то, что данные поступающих сделок и свечей синхронизированы?

Попробовал добавить склеивание исторических и онлайн свечей по Вашему совету в стандартный пример Sa...

2017-07-17T07:06:51Z

Попробовал добавить склеивание исторических и онлайн свечей по Вашему совету в стандартный пример SampleQuikCandles.
Ничего также не получилось.
Если в качестве коннектора использовать QuikTrader и потом вызывать InitializeStorage, передавая в него EntityRegistry и StorageRegistry, то в момент попытки коннекта появляется вот такая ошибка:
System.InvalidOperationException: Сообщение 'Connect,T(L)=2017/07/17 07:01:56.221,Error=Необходимо создать хотя бы одно подключение.' привело к ошибке обработки. ---> System.Collections.Generic.KeyNotFoundException: Данный ключ отсутствует в словаре.

Если же в качестве коннектора использовать Connector и передавать EntityRegistry и StorageRegistry в его конструктор, потом вручную добавлять квиковские адаптеры сообщений, то коннект проходит нормально, но свечи строятся только из поступающих онлайн тиков. Из хранилища никакой подгрузки данных не происходит.

После соединения коннектора подписываюсь на свечи в стратегии так: CandleManager candleManager = new...

2017-07-14T16:40:47Z

После соединения коннектора подписываюсь на свечи в стратегии так:
CandleManager candleManager = new CandleManager(connector);
CandleSeries candleSeries = new CandleSeries(typeof(TimeframeCandle, security, period);
candleSeries.BuildCandlesMode = BuildCandlesModes.Build;// LoadAndBuild я тоже пробовал
candleSeries.From = from;
candleSeries.To = DateTimeOffset.MaxValue;
candleManager.Start(candleSeries, from, DateTimeOffset.MaxValue);
strategy.Start();

А в методе OnStarted() стратегии выполняю:
candleManager.WhenCandlesFinished(candleSeries).Do(ProcessFinishedCandle).Apply(this);

Привет будет после обновления документации. А как вы подписываетесь на свечи?

2017-07-14T14:54:43Z

Привет будет после обновления документации.

А как вы подписываетесь на свечи?

Нет, не помогает. Я коннектор изначально создаю так: Connector connector = new Connector(entityRegis...

2017-07-14T11:01:57Z

Нет, не помогает.
Я коннектор изначально создаю так:
Connector connector = new Connector(entityRegistry, storageRegistry);
Потом добавляю в него адаптеры сообщений для квика.
Поэтому метод InitializeStorage запускается и без его прямого вызова. Хотя и если дополнительно вызвать, то все равно, свечи из сохраненных ранее тиков не строятся. Только из поступающих онлайн.
Он даже файлы с тиками из хранилища не подгружает (в окне output нет соответствующего сообщения).
Хотя при этом поступающие онлайн тики он в то же самое хранилище записывает успешно.

Может быть есть работающий пример?

Вот так попробуйте. 1. Инициализируем объект хранилища в коннекторе. var storage = new StorageRegist...

2017-07-12T13:50:51Z

Вот так попробуйте. 1. Инициализируем объект хранилища в коннекторе. var storage = new StorageRegistry() { DefaultDrive = new LocalMarketDataDrive() { Path = "datapath" } };
connector.InitializeStorage( new EntityRegistry(), storage );
2. Дальше коннектор должен сам склеивать свечи...