StorageHelper

StockSharp.Algo.Storages

Classe de extensão para armazenamento.

Métodos

ClearDatesCache
public static void ClearDatesCache(IMarketDataStorageDrive drive)
StorageHelper.ClearDatesCache(drive)

Embalagem sincronizada para CancellationToken).

drive
Unidade de armazenamento de dados de mercado.
Delete
public static void Delete(ISecurityStorage storage, Security security)
StorageHelper.Delete(storage, security)

Embalagem sincronizada para CancellationToken).

storage
armazenamento de instrumentos financeiros.
security
Instrumento financeiro.
Delete
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.
Delete
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.
Delete
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.
Delete
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.

DeleteAsync
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.

DeleteBy
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.
DeleteByIdAsync
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
DeleteByIdAsync
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
DeleteRange
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.
Delete``1
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.
FolderNameToSecurityId
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.

GetAvailableDataTypes
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.

GetCandleMessageBuildableStorage
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.

GetCandleMessageStorage
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.

GetCandleMessageStorage
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.

GetDates
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.

GetDates
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.

GetDates
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.

GetDatesAsync
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.

GetExecutionMessageStorage
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.

GetFromDate
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.

GetMetaInfo
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.

GetRange
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

GetRangeAsync
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

GetSnapshotStorage
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.

GetStorage
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.

GetStorage
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.

GetStorage
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.

GetTimeFrameCandleMessageStorage
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.

GetToDate
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.

Init
public static void Init(ISnapshotRegistry registry)
StorageHelper.Init(registry)
Init
public static void Init(IEntityRegistry registry)
StorageHelper.Init(registry)
Init
public static void Init(IExchangeInfoProvider provider)
StorageHelper.Init(provider)
Load
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.

LoadAsync``1
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.

LoadMessages
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.

LoadMessagesAsync
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.

LoadStream
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.

Load``1
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.

Load``1
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.

Save
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.

Save
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.
SaveStream
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.
Save``1
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.

SecurityIdToFolderName
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.

SetAdapter``1
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

SecurityBackslashSeparator
public const string SecurityBackslashSeparator
value = StorageHelper.SecurityBackslashSeparator

O delimitador, substituindo '\\' no caminho para instrumentos com ID como USD\\ EUR. É igual a '##BS##'.

SecurityColonSeparator
public const string SecurityColonSeparator
value = StorageHelper.SecurityColonSeparator

O delimitador, substituindo ':' no caminho para instrumentos com id como AA-CA:SPB@SPBEX. É igual a '##COLON##'.

SecurityFirstDot
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##'.

SecurityQuestionSeparator
public const string SecurityQuestionSeparator
value = StorageHelper.SecurityQuestionSeparator

O delimitador, substituindo '?' no caminho para instrumentos com id como AA-CA?SPB@SPBEX. É igual a '##QSTN##'.

SecuritySlashSeparator
public const string SecuritySlashSeparator
value = StorageHelper.SecuritySlashSeparator

O delimitador, substituindo '/' no caminho para instrumentos com ID como USD/EUR. É igual a '__'.

SecurityStarSeparator
public const string SecurityStarSeparator
value = StorageHelper.SecurityStarSeparator

O delimitador, substituindo '*' no caminho para instrumentos com id como C.BPO-*@CANADIAN. É igual a '##STAR##'.

SecurityVerticalBarSeparator
public const string SecurityVerticalBarSeparator
value = StorageHelper.SecurityVerticalBarSeparator

O delimitador, substituindo ''' no caminho para instrumentos com id como AA-CA .SPB@ SPBEX. É igual a '# #VBAR##'.