StorageHelper
Classe de extensão para armazenamento.
Métodos
public static void ClearDatesCache(IMarketDataStorageDrive drive)
StorageHelper.ClearDatesCache(drive)
Embalagem sincronizada para CancellationToken).
- drive
- Unidade de armazenamento de dados de mercado.
public static void Delete(ISecurityStorage storage, Security security)
StorageHelper.Delete(storage, security)
Embalagem sincronizada para CancellationToken).
- storage
- armazenamento de instrumentos financeiros.
- security
- Instrumento financeiro.
public static void Delete(IMarketDataStorageDrive drive, DateTime date)
StorageHelper.Delete(drive, date)
Embalagem sincronizada para CancellationToken).
- drive
- Unidade de armazenamento de dados de mercado.
- date
- Data, para a qual todos os dados são suprimidos.
public static void Delete(IMarketDataStorage storage, IEnumerable<Message> data)
StorageHelper.Delete(storage, data)
Embalagem sincronizada para CancellationToken).
- storage
- Armazenamento de dados de mercado.
- data
- Dados de mercado a suprimir.
public static void Delete(IMarketDataStorage storage, DateTime date)
StorageHelper.Delete(storage, date)
Embalagem sincronizada para CancellationToken).
- storage
- Armazenamento de dados de mercado.
- date
- Data, para a qual todos os dados são suprimidos.
public static bool Delete(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.Delete(storage, from, to)
Apagar os dados de mercado do armazenamento durante o período de tempo especificado.
- storage
- Armazenagem de dados de mercado.
- from
- A hora de início para a remoção dos dados. Se o valor não for especificado, os dados serão excluídos a partir da data GetDatesAsync.
- to
- A hora final, até à qual os dados serão apagados. Se o valor não for especificado, os dados serão apagados até à data final GetDatesAsync, inclusive.
Retorna: Se os dados tiverem sido suprimidos, não existem dados para o período especificado.
public static ValueTask<bool> DeleteAsync(IMarketDataStorage storage, DateTime? from, DateTime? to, CancellationToken cancellationToken)
result = StorageHelper.DeleteAsync(storage, from, to, cancellationToken)
Apagar os dados de mercado do armazenamento durante o período de tempo especificado.
- storage
- Armazenagem de dados de mercado.
- from
- A hora de início para a remoção dos dados. Se o valor não for especificado, os dados serão excluídos a partir da data GetDatesAsync.
- to
- A hora final, até à qual os dados serão apagados. Se o valor não for especificado, os dados serão apagados até à data final GetDatesAsync, inclusive.
- cancellationToken
- CancellationToken
Retorna: Se os dados tiverem sido suprimidos, não existem dados para o período especificado.
public static void DeleteBy(ISecurityStorage storage, SecurityLookupMessage criteria)
StorageHelper.DeleteBy(storage, criteria)
Embalagem sincronizada para CancellationToken).
- storage
- armazenamento de instrumentos financeiros.
- criteria
- O critério.
public static ValueTask DeleteByIdAsync(ISecurityStorage securityStorage, string securityId, CancellationToken cancellationToken)
result = StorageHelper.DeleteByIdAsync(securityStorage, securityId, cancellationToken)
Apagar o instrumento pelo identificador.
- securityStorage
- instrumentos financeiros meta info storage.
- securityId
- Identificador.
- cancellationToken
- CancellationToken
public static ValueTask DeleteByIdAsync(ISecurityStorage securityStorage, SecurityId securityId, CancellationToken cancellationToken)
result = StorageHelper.DeleteByIdAsync(securityStorage, securityId, cancellationToken)
Apagar o instrumento pelo identificador.
- securityStorage
- instrumentos financeiros meta info storage.
- securityId
- Identificador.
- cancellationToken
- CancellationToken
public static void DeleteRange(ISecurityStorage storage, IEnumerable<Security> securities)
StorageHelper.DeleteRange(storage, securities)
Embalagem sincronizada para CancellationToken).
- storage
- armazenamento de instrumentos financeiros.
- securities
- Instrumentos financeiros.
public static void Delete<TMessage>(IMarketDataStorage<TMessage> storage, IEnumerable<TMessage> data)
StorageHelper.Delete(storage, data)
Embalagem sincronizada para CancellationToken).
- storage
- Armazenamento de dados de mercado.
- data
- Dados de mercado a suprimir.
public static string FolderNameToSecurityId(string folderName)
result = StorageHelper.FolderNameToSecurityId(folderName)
A conversão inversa do método String).
- folderName
- Nome da pasta.
Retorna: ID do instrumento financeiro.
public static IEnumerable<DataType> GetAvailableDataTypes(IMarketDataDrive drive, SecurityId securityId, StorageFormats format)
result = StorageHelper.GetAvailableDataTypes(drive, securityId, format)
Obter todos os tipos de dados disponíveis.
- drive
- IMarketDataDrive
- securityId
- Identificador do instrumento.
- format
- Tipo de formato.
Retorna: Tipos de dados.
public static ValueTask<IMarketDataStorage<CandleMessage>> GetCandleMessageBuildableStorage(CandleBuilderProvider provider, IStorageRegistry registry, SecurityId securityId, TimeSpan timeFrame, IMarketDataDrive drive, StorageFormats format, CancellationToken cancellationToken)
result = StorageHelper.GetCandleMessageBuildableStorage(provider, registry, securityId, timeFrame, drive, format, cancellationToken)
Para obter o armazenamento das velas para o instrumento especificado. O armazenamento irá construir velas de prazos menores se não existirem prazos originais.
- provider
- Fornecedor de velas.
- registry
- Armazenagem de dados de mercado.
- securityId
- ID do instrumento financeiro.
- timeFrame
- Tempo-limite.
- drive
- O armazenamento. Se um valor for , DefaultDrive será usado.
- format
- O tipo de formato. Por omissão, o binário é passado.
- cancellationToken
- CancellationToken
Retorna: O armazém das velas.
public static IMarketDataStorage<CandleMessage> GetCandleMessageStorage(IStorageRegistry registry, Subscription subscription, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetCandleMessageStorage(registry, subscription, drive, format)
Para obter o armazenamento de velas para o instrumento especificado.
- registry
- IStorageRegistry.
- subscription
- Assinatura.
- drive
- O armazém.
- format
- O tipo de formato.
Retorna: O armazém das velas.
public static IMarketDataStorage<CandleMessage> GetCandleMessageStorage(IStorageRegistry registry, Type candleMessageType, SecurityId securityId, object arg, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetCandleMessageStorage(registry, candleMessageType, securityId, arg, drive, format)
Para obter o armazenamento de velas para o instrumento especificado.
- registry
- IStorageRegistry
- candleMessageType
- O tipo de mensagem de vela.
- securityId
- ID do instrumento financeiro.
- arg
- - Candle Arg.
- drive
- O armazém.
- format
- O tipo de formato.
Retorna: O armazém das velas.
public static IEnumerable<DateTime> GetDates(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.GetDates(storage, from, to)
Para obter todas as datas para dados de mercado armazenados para o intervalo especificado.
- storage
- Armazenagem de dados de mercado.
- from
- A hora de início do intervalo. Se o valor não for especificado, os dados serão carregados a partir da data de início GetDatesAsync.
- to
- A hora final do intervalo. Se o valor não for especificado, os dados serão carregados até à data final GetDatesAsync, inclusive.
Retorna: Todos os dados disponíveis dentro do intervalo.
public static IEnumerable<DateTime> GetDates(IMarketDataStorageDrive drive)
result = StorageHelper.GetDates(drive)
Embalagem sincronizada para GetDatesAsync.
- drive
- Unidade de armazenamento de dados de mercado.
Retorna: Datas disponíveis.
public static IEnumerable<DateTime> GetDates(IMarketDataStorage storage)
result = StorageHelper.GetDates(storage)
Embalagem sincronizada para GetDatesAsync.
- storage
- Armazenamento de dados de mercado.
Retorna: Datas disponíveis.
public static IAsyncEnumerable<DateTime> GetDatesAsync(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.GetDatesAsync(storage, from, to)
Para obter todas as datas para dados de mercado armazenados para o intervalo especificado.
- storage
- Armazenagem de dados de mercado.
- from
- A hora de início do intervalo. Se o valor não for especificado, os dados serão carregados a partir da data de início GetDatesAsync.
- to
- A hora final do intervalo. Se o valor não for especificado, os dados serão carregados até à data final GetDatesAsync, inclusive.
Retorna: Todos os dados disponíveis dentro do intervalo.
public static IMarketDataStorage<ExecutionMessage> GetExecutionMessageStorage(IStorageRegistry registry, SecurityId securityId, ExecutionTypes type, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetExecutionMessageStorage(registry, securityId, type, drive, format)
Para obter o armazenamento ExecutionMessage para o instrumento especificado.
- registry
- IStorageRegistry
- securityId
- ID do instrumento financeiro.
- type
- Tipo de dados, informações sobre as quais está contido no ExecutionMessage.
- drive
- O armazém.
- format
- O tipo de formato.
Retorna: O armazenamento ExecutionMessage.
public static DateTime? GetFromDate(IMarketDataStorage storage)
result = StorageHelper.GetFromDate(storage)
Para obter a data de início dos dados do mercado, armazenados no armazenamento.
- storage
- Armazenagem de dados de mercado.
Retorna: A data de início. Se o valor não for inicializado, o armazenamento estará em branco.
public static IMarketDataMetaInfo GetMetaInfo(IMarketDataStorage storage, DateTime date)
result = StorageHelper.GetMetaInfo(storage, date)
Embalagem sincronizada para CancellationToken).
- storage
- Armazenamento de dados de mercado.
- date
- Data para a qual devem ser recebidas meta-informações sobre os dados.
Retorna: Meta- informação sobre dados. Se não existir tal data no histórico, será devolvida.
public static IRange<DateTime> GetRange(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.GetRange(storage, from, to)
Obter intervalo de data disponível para o armazenamento especificado.
- storage
- Armazenagem.
- from
- A data inicial a partir da qual você precisa obter dados.
- to
- A data final pela qual você precisa obter dados.
Retorna: Período
public static ValueTask<IRange<DateTime>> GetRangeAsync(IMarketDataStorage storage, DateTime? from, DateTime? to, CancellationToken cancellationToken)
result = StorageHelper.GetRangeAsync(storage, from, to, cancellationToken)
Obter intervalo de data disponível para o armazenamento especificado.
- storage
- Armazenagem.
- from
- A data inicial a partir da qual você precisa obter dados.
- to
- A data final pela qual você precisa obter dados.
- cancellationToken
- CancellationToken
Retorna: Período
public static ISnapshotStorage GetSnapshotStorage(ISnapshotRegistry registry, Type dataType, object arg)
result = StorageHelper.GetSnapshotStorage(registry, dataType, arg)
Para obter o armazenamento instantâneo.
- registry
- Registo de armazenamento de instantâneos.
- dataType
- Tipo de dados do mercado.
- arg
- O parâmetro associado ao tipo. Por exemplo, o arg da vela.
Retorna: O armazenamento de instantâneos.
public static IMarketDataStorage GetStorage(IStorageRegistry registry, SecurityId securityId, Type dataType, object arg, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetStorage(registry, securityId, dataType, arg, drive, format)
Para obter o armazenamento de dados do mercado.
- registry
- IStorageRegistry
- securityId
- ID do instrumento financeiro.
- dataType
- Tipo de dados do mercado.
- arg
- O parâmetro associado ao tipo. Por exemplo, o arg da vela.
- drive
- O armazém.
- format
- O tipo de formato.
Retorna: Armazenagem de dados de mercado.
public static IMarketDataStorage GetStorage(IStorageRegistry registry, Security security, Type dataType, object arg, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetStorage(registry, security, dataType, arg, drive, format)
Para obter o armazenamento de dados do mercado.
- registry
- IStorageRegistry
- security
- Instrumento financeiro.
- dataType
- Tipo de dados do mercado.
- arg
- O parâmetro associado ao tipo. Por exemplo, o arg da vela.
- drive
- O armazenamento. Se um valor for , DefaultDrive será usado.
- format
- O tipo de formato. Por omissão, o binário é passado.
Retorna: Armazenagem de dados de mercado.
public static IMarketDataStorage GetStorage(IStorageRegistry registry, Security security, DataType dataType, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetStorage(registry, security, dataType, drive, format)
Para obter o armazenamento de dados do mercado.
- registry
- Armazenagem de dados de mercado.
- security
- Instrumento financeiro.
- dataType
- Informação do tipo de dados.
- drive
- O armazenamento. Se um valor for , DefaultDrive será usado.
- format
- O tipo de formato. Por omissão, o binário é passado.
Retorna: Armazenagem de dados de mercado.
public static IMarketDataStorage<CandleMessage> GetTimeFrameCandleMessageStorage(IStorageRegistry registry, SecurityId securityId, TimeSpan arg, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetTimeFrameCandleMessageStorage(registry, securityId, arg, drive, format)
Para obter o armazenamento de velas para o instrumento especificado.
- registry
- IStorageRegistry.
- securityId
- ID do instrumento financeiro.
- arg
- - Candle Arg.
- drive
- O armazém.
- format
- O tipo de formato.
Retorna: O armazém das velas.
public static DateTime? GetToDate(IMarketDataStorage storage)
result = StorageHelper.GetToDate(storage)
Para obter a data final para os dados do mercado, armazenados no armazenamento.
- storage
- Armazenagem de dados de mercado.
Retorna: A data final. Se o valor não for inicializado, o armazenamento estará vazio.
public static IEnumerable<Message> Load(IMarketDataStorage storage, DateTime date)
result = StorageHelper.Load(storage, date)
Embalagem sincronizada para DateTime).
- storage
- Armazenamento de dados de mercado.
- date
- Data para a qual os dados devem ser carregados.
Retorna: Dados. Se não houver dados, o conjunto vazio será devolvido.
public static IAsyncEnumerable<TMessage> LoadAsync<TMessage>(IMarketDataStorage<TMessage> storage, DateTime? from, DateTime? to)
result = StorageHelper.LoadAsync(storage, from, to)
Para criar um carregador iterativo de dados de mercado para o intervalo de tempo.
- storage
- Armazenagem de dados de mercado.
- from
- A hora de início para o carregamento dos dados. Se o valor não for especificado, os dados serão carregados a partir do tempo de início GetDatesAsync.
- to
- A hora final para o carregamento dos dados. Se o valor não for especificado, os dados serão carregados até GetDatesAsync date, inclusive.
Retorna: O carregador iterativo de dados de mercado.
public static ValueTuple<DateTime?, long?>? LoadMessages(StorageCoreSettings settings, CandleBuilderProvider candleBuilderProvider, MarketDataMessage subscription, Action<Message> newOutMessage)
result = StorageHelper.LoadMessages(settings, candleBuilderProvider, subscription, newOutMessage)
Carregar mensagens.
- settings
- Configuração do armazenamento.
- candleBuilderProvider
- Fornecedor de velas.
- subscription
- Mensagem de dados de mercado (usa como um subscribe/dessubscreva em caso de saída, evento de confirmação em caso de entrada).
- newOutMessage
- Novo evento de mensagem.
Retorna: Último encontro.
public static IAsyncEnumerable<Message> LoadMessagesAsync(StorageCoreSettings settings, CandleBuilderProvider candleBuilderProvider, MarketDataMessage subscription, StorageLoadContext context, CancellationToken cancellationToken)
result = StorageHelper.LoadMessagesAsync(settings, candleBuilderProvider, subscription, context, cancellationToken)
Carregar as mensagens de histórico do armazenamento como um fluxo de assync.
- settings
- Configuração do armazenamento.
- candleBuilderProvider
- Fornecedor de velas.
- subscription
- Mensagem de dados de mercado (usa como um subscribe/dessubscreva em caso de saída, evento de confirmação em caso de entrada).
- context
- Contexto que será preenchido com metadados de resultado de carga após enumeração.
- cancellationToken
- Inscrição de cancelamento.
Retorna: Sincronizar o fluxo de mensagens.
public static Stream LoadStream(IMarketDataStorageDrive drive, DateTime date, bool readOnly)
result = StorageHelper.LoadStream(drive, date, readOnly)
Embalagem sincronizada para CancellationToken).
- drive
- Unidade de armazenamento de dados de mercado.
- date
- Data para a qual os dados devem ser carregados.
- readOnly
- Obter apenas o fluxo no modo de leitura.
Retorna: Dados no formato de StockSharp storage. Se não existirem dados, Null será devolvido.
public static IEnumerable<TMessage> Load<TMessage>(IMarketDataStorage<TMessage> storage, DateTime date)
result = StorageHelper.Load(storage, date)
Embalagem sincronizada para DateTime).
- storage
- Armazenamento de dados de mercado.
- date
- Data para a qual os dados devem ser carregados.
Retorna: Dados. Se não houver dados, o conjunto vazio será devolvido.
public static IEnumerable<TMessage> Load<TMessage>(IMarketDataStorage<TMessage> storage, DateTime? from, DateTime? to)
result = StorageHelper.Load(storage, from, to)
Para criar um carregador iterativo de dados de mercado para o intervalo de tempo.
- storage
- Armazenagem de dados de mercado.
- from
- A hora de início para o carregamento dos dados. Se o valor não for especificado, os dados serão carregados a partir do tempo de início GetDatesAsync.
- to
- A hora final para o carregamento dos dados. Se o valor não for especificado, os dados serão carregados até GetDatesAsync date, inclusive.
Retorna: O carregador iterativo de dados de mercado.
public static int Save(IMarketDataStorage storage, IEnumerable<Message> data)
result = StorageHelper.Save(storage, data)
Embalagem sincronizada para CancellationToken).
- storage
- Armazenamento de dados de mercado.
- data
- Dados de mercado.
Retorna: Contagem de dados salvos.
public static void Save(ISecurityStorage storage, Security security, bool forced)
StorageHelper.Save(storage, security, forced)
Embalagem sincronizada para CancellationToken).
- storage
- armazenamento de instrumentos financeiros.
- security
- Instrumento financeiro.
- forced
- Actualização forçada.
public static void SaveStream(IMarketDataStorageDrive drive, DateTime date, Stream stream)
StorageHelper.SaveStream(drive, date, stream)
Embalagem sincronizada para CancellationToken).
- drive
- Unidade de armazenamento de dados de mercado.
- date
- Data em que os dados serão guardados.
- stream
- Dados no formato de StockSharp storage.
public static int Save<TMessage>(IMarketDataStorage<TMessage> storage, IEnumerable<TMessage> data)
result = StorageHelper.Save(storage, data)
Embalagem sincronizada para CancellationToken).
- storage
- Armazenamento de dados de mercado.
- data
- Dados de mercado.
Retorna: Contagem de dados salvos.
public static string SecurityIdToFolderName(string id)
result = StorageHelper.SecurityIdToFolderName(id)
Para converter o identificador do instrumento no nome da pasta, substituindo símbolos reservados.
- id
- ID do instrumento financeiro.
Retorna: Nome da pasta.
public static bool SetAdapter<TKey>(IMappingMessageAdapterProvider<TKey> provider, TKey key, IMessageAdapter adapter)
result = StorageHelper.SetAdapter(provider, key, adapter)
Faça associação com o adaptador.
- provider
- Interface de provedor de adaptador de mensagens.
- key
- Chave.
- adapter
- Adaptador.
Retorna: se a associação for alterada com sucesso, caso contrário, .
Campos
public const string SecurityBackslashSeparator
value = StorageHelper.SecurityBackslashSeparator
O delimitador, substituindo '\\' no caminho para instrumentos com ID como USD\\ EUR. É igual a '##BS##'.
public const string SecurityColonSeparator
value = StorageHelper.SecurityColonSeparator
O delimitador, substituindo ':' no caminho para instrumentos com id como AA-CA:SPB@SPBEX. É igual a '##COLON##'.
public const string SecurityFirstDot
value = StorageHelper.SecurityFirstDot
O delimitador, substituindo o primeiro '.' no caminho para instrumentos com id como .AA-CA@SPBEX. É igual a '##DOT##'.
public const string SecurityQuestionSeparator
value = StorageHelper.SecurityQuestionSeparator
O delimitador, substituindo '?' no caminho para instrumentos com id como AA-CA?SPB@SPBEX. É igual a '##QSTN##'.
public const string SecuritySlashSeparator
value = StorageHelper.SecuritySlashSeparator
O delimitador, substituindo '/' no caminho para instrumentos com ID como USD/EUR. É igual a '__'.
public const string SecurityStarSeparator
value = StorageHelper.SecurityStarSeparator
O delimitador, substituindo '*' no caminho para instrumentos com id como C.BPO-*@CANADIAN. É igual a '##STAR##'.
public const string SecurityVerticalBarSeparator
value = StorageHelper.SecurityVerticalBarSeparator
O delimitador, substituindo ''' no caminho para instrumentos com id como AA-CA .SPB@ SPBEX. É igual a '# #VBAR##'.