StorageHelper

StockSharp.Algo.Storages

Clase de extensión para almacenamiento.

Métodos

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

Envoltura sincronizada para CancellationToken).

drive
Unidad de almacenamiento de datos de mercado.
Delete
public static void Delete(ISecurityStorage storage, Security security)
StorageHelper.Delete(storage, security)

Envoltura sincronizada para CancellationToken).

storage
almacenamiento de instrumentos financieros.
security
instrumento financiero.
Delete
public static void Delete(IMarketDataStorageDrive drive, DateTime date)
StorageHelper.Delete(drive, date)

Envoltura sincronizada para CancellationToken).

drive
Unidad de almacenamiento de datos de mercado.
date
Fecha, para la cual se eliminarán todos los datos.
Delete
public static void Delete(IMarketDataStorage storage, IEnumerable<Message> data)
StorageHelper.Delete(storage, data)

Envoltura sincronizada para CancellationToken).

storage
Almacenamiento de datos de mercado.
data
Datos de mercado que se eliminarán.
Delete
public static void Delete(IMarketDataStorage storage, DateTime date)
StorageHelper.Delete(storage, date)

Envoltura sincronizada para CancellationToken).

storage
Almacenamiento de datos de mercado.
date
Fecha, para la cual se eliminarán todos los datos.
Delete
public static bool Delete(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.Delete(storage, from, to)

Eliminar los datos del mercado del almacenamiento para el período de tiempo especificado.

storage
Almacenamiento de datos de mercado.
from
El tiempo de inicio para la eliminación de datos. Si el valor no se especifica, los datos serán eliminados a partir de la fecha GetDatesAsync@.
to
El tiempo final, hasta el cual se eliminarán los datos. Si el valor no se especifica, los datos serán eliminados hasta la fecha final GetDatesAsync, inclusive.

Devuelve: si se eliminan los datos, no existen datos para el período especificado.

DeleteAsync
public static ValueTask<bool> DeleteAsync(IMarketDataStorage storage, DateTime? from, DateTime? to, CancellationToken cancellationToken)
result = StorageHelper.DeleteAsync(storage, from, to, cancellationToken)

Eliminar los datos del mercado del almacenamiento para el período de tiempo especificado.

storage
Almacenamiento de datos de mercado.
from
El tiempo de inicio para la eliminación de datos. Si el valor no se especifica, los datos serán eliminados a partir de la fecha GetDatesAsync@.
to
El tiempo final, hasta el cual se eliminarán los datos. Si el valor no se especifica, los datos serán eliminados hasta la fecha final GetDatesAsync, inclusive.
cancellationToken
CancellationToken

Devuelve: si se eliminan los datos, no existen datos para el período especificado.

DeleteBy
public static void DeleteBy(ISecurityStorage storage, SecurityLookupMessage criteria)
StorageHelper.DeleteBy(storage, criteria)

Envoltura sincronizada para CancellationToken).

storage
almacenamiento de instrumentos financieros.
criteria
El criterio.
DeleteByIdAsync
public static ValueTask DeleteByIdAsync(ISecurityStorage securityStorage, string securityId, CancellationToken cancellationToken)
result = StorageHelper.DeleteByIdAsync(securityStorage, securityId, cancellationToken)

Eliminar el instrumento por identificador.

securityStorage
instrumentos financieros meta almacenamiento de información.
securityId
Identificador.
cancellationToken
CancellationToken
DeleteByIdAsync
public static ValueTask DeleteByIdAsync(ISecurityStorage securityStorage, SecurityId securityId, CancellationToken cancellationToken)
result = StorageHelper.DeleteByIdAsync(securityStorage, securityId, cancellationToken)

Eliminar el instrumento por identificador.

securityStorage
instrumentos financieros meta almacenamiento de información.
securityId
Identificador.
cancellationToken
CancellationToken
DeleteRange
public static void DeleteRange(ISecurityStorage storage, IEnumerable<Security> securities)
StorageHelper.DeleteRange(storage, securities)

Envoltura sincronizada para CancellationToken).

storage
almacenamiento de instrumentos financieros.
securities
instrumentos financieros.
Delete``1
public static void Delete<TMessage>(IMarketDataStorage<TMessage> storage, IEnumerable<TMessage> data)
StorageHelper.Delete(storage, data)

Envoltura sincronizada para CancellationToken).

storage
Almacenamiento de datos de mercado.
data
Datos de mercado que se eliminarán.
FolderNameToSecurityId
public static string FolderNameToSecurityId(string folderName)
result = StorageHelper.FolderNameToSecurityId(folderName)

La conversión inversa del método String.

folderName
Nombre del directorio.

Devuelve: identificación de instrumentos financieros.

GetAvailableDataTypes
public static IEnumerable<DataType> GetAvailableDataTypes(IMarketDataDrive drive, SecurityId securityId, StorageFormats format)
result = StorageHelper.GetAvailableDataTypes(drive, securityId, format)

Obtenga todos los tipos de datos disponibles.

drive
IMarketDataDrive
securityId
Identificador de instrumentos.
format
Tipo de formato.

Devuelve: Tipos de datos.

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 obtener el almacenamiento de velas para el instrumento especificado. El almacenamiento construirá velas desde marcos temporales más pequeños si no existen marcos temporales originales.

provider
Proveedor de constructores de velas.
registry
Almacenamiento de datos de mercado.
securityId
identificación de instrumentos financieros.
timeFrame
Time-frame.
drive
El almacenamiento. Si un valor es , DefaultDrive se utilizará.
format
El tipo de formato. Por defecto se pasa binario.
cancellationToken
CancellationToken

Devuelve: El almacenamiento de velas.

GetCandleMessageStorage
public static IMarketDataStorage<CandleMessage> GetCandleMessageStorage(IStorageRegistry registry, Subscription subscription, IMarketDataDrive drive, StorageFormats format)
result = StorageHelper.GetCandleMessageStorage(registry, subscription, drive, format)

Para obtener el almacenamiento de velas para el instrumento especificado.

registry
IStorageRegistry.
subscription
Suscripción.
drive
El almacenamiento.
format
El tipo de formato.

Devuelve: El almacenamiento de 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 obtener el almacenamiento de velas para el instrumento especificado.

registry
IStorageRegistry
candleMessageType
El tipo de mensaje de la vela.
securityId
identificación de instrumentos financieros.
arg
Arg de vela.
drive
El almacenamiento.
format
El tipo de formato.

Devuelve: El almacenamiento de velas.

GetDates
public static IEnumerable<DateTime> GetDates(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.GetDates(storage, from, to)

Para obtener todas las fechas de los datos del mercado almacenados para el rango especificado.

storage
Almacenamiento de datos de mercado.
from
El tiempo de inicio del rango. Si el valor no se especifica, los datos se cargarán desde la fecha de inicio GetDatesAsync@.
to
El tiempo de finalización del rango. Si el valor no se especifica, los datos se cargarán hasta la fecha final GetDatesAsync@, inclusive.

Devuelve: Todos los datos disponibles dentro del rango.

GetDates
public static IEnumerable<DateTime> GetDates(IMarketDataStorageDrive drive)
result = StorageHelper.GetDates(drive)

Envoltorio sincronizado para GetDatesAsync.

drive
Unidad de almacenamiento de datos de mercado.

Devuelve: Fechas disponibles.

GetDates
public static IEnumerable<DateTime> GetDates(IMarketDataStorage storage)
result = StorageHelper.GetDates(storage)

Envoltorio sincronizado para GetDatesAsync.

storage
Almacenamiento de datos de mercado.

Devuelve: Fechas disponibles.

GetDatesAsync
public static IAsyncEnumerable<DateTime> GetDatesAsync(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.GetDatesAsync(storage, from, to)

Para obtener todas las fechas de los datos del mercado almacenados para el rango especificado.

storage
Almacenamiento de datos de mercado.
from
El tiempo de inicio del rango. Si el valor no se especifica, los datos se cargarán desde la fecha de inicio GetDatesAsync@.
to
El tiempo de finalización del rango. Si el valor no se especifica, los datos se cargarán hasta la fecha final GetDatesAsync@, inclusive.

Devuelve: Todos los datos disponibles dentro del rango.

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 obtener el almacenamiento ExecutionMessage para el instrumento especificado.

registry
IStorageRegistry
securityId
identificación de instrumentos financieros.
type
Tipo de datos, información sobre la que se encuentra en la ExecutionMessage@.
drive
El almacenamiento.
format
El tipo de formato.

Devuelve: El almacenamiento ExecutionMessage.

GetFromDate
public static DateTime? GetFromDate(IMarketDataStorage storage)
result = StorageHelper.GetFromDate(storage)

Para obtener la fecha de inicio de los datos del mercado, almacenados en el almacenamiento.

storage
Almacenamiento de datos de mercado.

Devuelve: La fecha de inicio. Si el valor no se inicializa, el almacenamiento está vacío.

GetMetaInfo
public static IMarketDataMetaInfo GetMetaInfo(IMarketDataStorage storage, DateTime date)
result = StorageHelper.GetMetaInfo(storage, date)

Envoltura sincronizada para CancellationToken).

storage
Almacenamiento de datos de mercado.
date
Fecha, para la cual se recibirá la metainformación sobre los datos.

Devuelve: Metainformación sobre datos. Si no hay tal fecha en la historia, será devuelto.

GetRange
public static IRange<DateTime> GetRange(IMarketDataStorage storage, DateTime? from, DateTime? to)
result = StorageHelper.GetRange(storage, from, to)

Obtenga el rango de fecha disponible para el almacenamiento especificado.

storage
Almacenamiento.
from
La fecha inicial de la que necesita obtener datos.
to
La fecha final por la que necesita obtener datos.

Devuelve: Gama de fecha

GetRangeAsync
public static ValueTask<IRange<DateTime>> GetRangeAsync(IMarketDataStorage storage, DateTime? from, DateTime? to, CancellationToken cancellationToken)
result = StorageHelper.GetRangeAsync(storage, from, to, cancellationToken)

Obtenga el rango de fecha disponible para el almacenamiento especificado.

storage
Almacenamiento.
from
La fecha inicial de la que necesita obtener datos.
to
La fecha final por la que necesita obtener datos.
cancellationToken
CancellationToken

Devuelve: Gama de fecha

GetSnapshotStorage
public static ISnapshotStorage GetSnapshotStorage(ISnapshotRegistry registry, Type dataType, object arg)
result = StorageHelper.GetSnapshotStorage(registry, dataType, arg)

Para conseguir el almacenamiento de instantáneas.

registry
Registro de almacenamiento de instantáneas.
dataType
Tipo de datos de mercado.
arg
El parámetro asociado con el tipo. Por ejemplo, la arg de vela.

Devuelve: El almacenamiento de instantáneas.

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 conseguir el almacenamiento de datos de mercado.

registry
IStorageRegistry
securityId
identificación de instrumentos financieros.
dataType
Tipo de datos de mercado.
arg
El parámetro asociado con el tipo. Por ejemplo, la arg de vela.
drive
El almacenamiento.
format
El tipo de formato.

Devuelve: Almacenamiento de datos 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 conseguir el almacenamiento de datos de mercado.

registry
IStorageRegistry
security
instrumento financiero.
dataType
Tipo de datos de mercado.
arg
El parámetro asociado con el tipo. Por ejemplo, la arg de vela.
drive
El almacenamiento. Si un valor es , DefaultDrive se utilizará.
format
El tipo de formato. Por defecto se pasa binario.

Devuelve: Almacenamiento de datos 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 conseguir el almacenamiento de datos de mercado.

registry
Almacenamiento de datos de mercado.
security
instrumento financiero.
dataType
Datos tipo info.
drive
El almacenamiento. Si un valor es , DefaultDrive se utilizará.
format
El tipo de formato. Por defecto se pasa binario.

Devuelve: Almacenamiento de datos 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 obtener el almacenamiento de velas para el instrumento especificado.

registry
IStorageRegistry.
securityId
identificación de instrumentos financieros.
arg
Arg de vela.
drive
El almacenamiento.
format
El tipo de formato.

Devuelve: El almacenamiento de velas.

GetToDate
public static DateTime? GetToDate(IMarketDataStorage storage)
result = StorageHelper.GetToDate(storage)

Para obtener la fecha final de los datos del mercado, almacenados en el almacenamiento.

storage
Almacenamiento de datos de mercado.

Devuelve: La fecha final. Si el valor no se inicializa, el almacenamiento está vacío.

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)

Envoltura sincronizada para DateTime).

storage
Almacenamiento de datos de mercado.
date
Fecha, para la cual se cargarán los datos.

Devuelve: Datos. Si no hay datos, el conjunto vacío será devuelto.

LoadAsync``1
public static IAsyncEnumerable<TMessage> LoadAsync<TMessage>(IMarketDataStorage<TMessage> storage, DateTime? from, DateTime? to)
result = StorageHelper.LoadAsync(storage, from, to)

Para crear un cargador iterativo de datos de mercado para el rango de tiempo.

storage
Almacenamiento de datos de mercado.
from
El tiempo de inicio para la carga de datos. Si el valor no se especifica, los datos se cargarán desde el momento de inicio GetDatesAsync.
to
El tiempo final para la carga de datos. Si el valor no se especifica, los datos se cargarán hasta la fecha GetDatesAsync, inclusive.

Devuelve: El cargador iterativo de los datos del mercado.

LoadMessages
public static ValueTuple<DateTime?, long?>? LoadMessages(StorageCoreSettings settings, CandleBuilderProvider candleBuilderProvider, MarketDataMessage subscription, Action<Message> newOutMessage)
result = StorageHelper.LoadMessages(settings, candleBuilderProvider, subscription, newOutMessage)

Mensajes de carga.

settings
Ajustes de almacenamiento.
candleBuilderProvider
Proveedor de constructores de velas.
subscription
Mensaje de mercado-datos (usuarios como suscripto/no suscripción en caso saliente, evento de confirmación en caso entrante).
newOutMessage
Nuevo evento de mensaje.

Devuelve: Última cita.

LoadMessagesAsync
public static IAsyncEnumerable<Message> LoadMessagesAsync(StorageCoreSettings settings, CandleBuilderProvider candleBuilderProvider, MarketDataMessage subscription, StorageLoadContext context, CancellationToken cancellationToken)
result = StorageHelper.LoadMessagesAsync(settings, candleBuilderProvider, subscription, context, cancellationToken)

Cargar mensajes de historia desde el almacenamiento como flujo asinc.

settings
Ajustes de almacenamiento.
candleBuilderProvider
Proveedor de constructores de velas.
subscription
Mensaje de mercado-datos (usuarios como suscripto/no suscripción en caso saliente, evento de confirmación en caso entrante).
context
Contexto que se poblará con metadatos de resultado de carga después de la enumeración.
cancellationToken
Cancelación token.

Devuelve: Flujo de mensajes Async.

LoadStream
public static Stream LoadStream(IMarketDataStorageDrive drive, DateTime date, bool readOnly)
result = StorageHelper.LoadStream(drive, date, readOnly)

Envoltura sincronizada para CancellationToken).

drive
Unidad de almacenamiento de datos de mercado.
date
Fecha, para la cual se cargarán los datos.
readOnly
Obtener flujo en modo de lectura solamente.

Devuelve: Datos en formato de almacenamiento StockSharp. Si no hay datos, Null será devuelto.

Load``1
public static IEnumerable<TMessage> Load<TMessage>(IMarketDataStorage<TMessage> storage, DateTime date)
result = StorageHelper.Load(storage, date)

Envoltura sincronizada para DateTime).

storage
Almacenamiento de datos de mercado.
date
Fecha, para la cual se cargarán los datos.

Devuelve: Datos. Si no hay datos, el conjunto vacío será devuelto.

Load``1
public static IEnumerable<TMessage> Load<TMessage>(IMarketDataStorage<TMessage> storage, DateTime? from, DateTime? to)
result = StorageHelper.Load(storage, from, to)

Para crear un cargador iterativo de datos de mercado para el rango de tiempo.

storage
Almacenamiento de datos de mercado.
from
El tiempo de inicio para la carga de datos. Si el valor no se especifica, los datos se cargarán desde el momento de inicio GetDatesAsync.
to
El tiempo final para la carga de datos. Si el valor no se especifica, los datos se cargarán hasta la fecha GetDatesAsync, inclusive.

Devuelve: El cargador iterativo de los datos del mercado.

Save
public static int Save(IMarketDataStorage storage, IEnumerable<Message> data)
result = StorageHelper.Save(storage, data)

Envoltura sincronizada para CancellationToken).

storage
Almacenamiento de datos de mercado.
data
Datos de mercado.

Devuelve: Cuenta de datos guardados.

Save
public static void Save(ISecurityStorage storage, Security security, bool forced)
StorageHelper.Save(storage, security, forced)

Envoltura sincronizada para CancellationToken).

storage
almacenamiento de instrumentos financieros.
security
instrumento financiero.
forced
Actualización forzada.
SaveStream
public static void SaveStream(IMarketDataStorageDrive drive, DateTime date, Stream stream)
StorageHelper.SaveStream(drive, date, stream)

Envoltura sincronizada para CancellationToken).

drive
Unidad de almacenamiento de datos de mercado.
date
La fecha, para la cual se guardarán los datos.
stream
Datos en formato StockSharpalmacenamiento.
Save``1
public static int Save<TMessage>(IMarketDataStorage<TMessage> storage, IEnumerable<TMessage> data)
result = StorageHelper.Save(storage, data)

Envoltura sincronizada para CancellationToken).

storage
Almacenamiento de datos de mercado.
data
Datos de mercado.

Devuelve: Cuenta de datos guardados.

SecurityIdToFolderName
public static string SecurityIdToFolderName(string id)
result = StorageHelper.SecurityIdToFolderName(id)

Para convertir el identificador de instrumento en el nombre de la carpeta, reemplazando los símbolos reservados.

id
identificación de instrumentos financieros.

Devuelve: Nombre del directorio.

SetAdapter``1
public static bool SetAdapter<TKey>(IMappingMessageAdapterProvider<TKey> provider, TKey key, IMessageAdapter adapter)
result = StorageHelper.SetAdapter(provider, key, adapter)

Hacer asociación con adaptador.

provider
Interfaz de proveedor del adaptador de mensajes.
key
Llave.
adapter
Adaptador.

Devuelve: si la asociación es cambiada con éxito, de lo contrario, .

Campos

SecurityBackslashSeparator
public const string SecurityBackslashSeparator
value = StorageHelper.SecurityBackslashSeparator

El delimitador, reemplazando '\' en el camino para instrumentos con id como USD\EUR. Es igual a '##BS###'.

SecurityColonSeparator
public const string SecurityColonSeparator
value = StorageHelper.SecurityColonSeparator

El delimitador, reemplazando ':' en el camino para instrumentos con id como AA-CA:SPB@SPBEX. Es igual a '##COLON###'.

SecurityFirstDot
public const string SecurityFirstDot
value = StorageHelper.SecurityFirstDot

El delimitador, reemplazando primero '.' en el camino para instrumentos con id como .AA-CA@SPBEX. Es igual a '##DOT##'.

SecurityQuestionSeparator
public const string SecurityQuestionSeparator
value = StorageHelper.SecurityQuestionSeparator

El delimitador, sustituyendo '?' en el camino para instrumentos con id como AA-CA?SPB@SPBEX. Es igual a '##QSTN##'.

SecuritySlashSeparator
public const string SecuritySlashSeparator
value = StorageHelper.SecuritySlashSeparator

El delimitador, reemplazando '/' en camino por instrumentos con id como USD/EUR. Es igual a '__@'.

SecurityStarSeparator
public const string SecurityStarSeparator
value = StorageHelper.SecurityStarSeparator

El delimitador, reemplazando '*' en el camino por instrumentos con id como C.BPO-*@CANADIAN. Es igual a '##STAR##'.

SecurityVerticalBarSeparator
public const string SecurityVerticalBarSeparator
value = StorageHelper.SecurityVerticalBarSeparator

El delimitador, reemplazando 'la vida' en el camino por instrumentos con id como AA-CA, es igual a '##VBAR##'.