Раз нет больше CandleManager, сделал Connector. Как в примере:
_series = new CandleSeries(typeof(TimeFrameCandle), SecurityForResearchPicker.SelectedSecurity, _timeFrame); EntityRegistry er = new EntityRegistry(); SnapshotRegistry sr = new SnapshotRegistry(_path); RSafeConnection.Trader.InitializeStorage(er,_storage,sr); RSafeConnection.Trader.CandleSeriesProcessing += Connector_CandleSeriesProcessing; RSafeConnection.Trader.SubscribeCandles(_series, (DateTime)From_d.Value, (DateTime)To_d.Value);
В Connector_CandleSeriesProcessing пытаюсь вывести данные (исторические данные, которые скачала Hydra за последнюю неделю) Но ничего не выходит (в смысле, просто ничего не происходит). Логирование выдает такую вот ошибку:
"System.NotImplementedException: Метод или операция не реализована.
в Ecng.Serialization.InMemoryStorage.GetBy[TEntity](SerializationItemCollection by)
в Ecng.Serialization.RelationManyList1.OnGet(SerializationItemCollection by) в Ecng.Serialization.RelationManyList1.Read(SerializationItem by)
в Ecng.Serialization.RelationManyList1.ReadById(Object id) в StockSharp.Algo.Storages.StorageHelper.ReadBySecurityId(IStorageEntityList1 securities, SecurityId securityId)
в StockSharp.Algo.Storages.StorageMessageAdapter.GetSecurity(SecurityId securityId)
в StockSharp.Algo.Storages.StorageMessageAdapter.GetTimeFrameCandleMessageStorage(SecurityId securityId, TimeSpan timeFrame, Boolean allowBuildFromSmallerTimeFrame)
в StockSharp.Algo.Storages.StorageMessageAdapter.LoadMessages(MarketDataMessage msg, Nullable1 from, Nullable1 to, Int64 transactionId)
в StockSharp.Algo.Storages.StorageMessageAdapter.ProcessMarketDataRequest(MarketDataMessage msg)
в StockSharp.Algo.Storages.StorageMessageAdapter.SendInMessage(Message message)
в StockSharp.Messages.MessageAdapterWrapper.SendInMessage(Message message)
в StockSharp.Algo.FilteredMarketDepthAdapter.SendInMessage(Message message)
в StockSharp.Algo.Connector.InMessageChannelOnNewOutMessage(Message message)
в StockSharp.Messages.InMemoryMessageChannel.OnNewOut(KeyValuePair2 item) в Ecng.Collections.BaseInMemoryChannel1.<Open>b__16_1()"
Буду очень признателен за помощь!
评论 (0)
登录 或 创建账户, 登录或注册以发表评论
暂无评论,成为第一个评论者!