StorageHelper
Clase de extensión para almacenamiento.
Métodos
public static void ClearDatesCache(IMarketDataStorageDrive drive)
StorageHelper.ClearDatesCache(drive)
Envoltura sincronizada para CancellationToken).
- drive
- Unidad de almacenamiento de datos de mercado.
public static void Delete(ISecurityStorage storage, Security security)
StorageHelper.Delete(storage, security)
Envoltura sincronizada para CancellationToken).
- storage
- almacenamiento de instrumentos financieros.
- security
- instrumento financiero.
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.
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.
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.
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.
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.
public static void DeleteBy(ISecurityStorage storage, SecurityLookupMessage criteria)
StorageHelper.DeleteBy(storage, criteria)
Envoltura sincronizada para CancellationToken).
- storage
- almacenamiento de instrumentos financieros.
- criteria
- El criterio.
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
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
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.
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.
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.
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.
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.
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.
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.
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.
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.
public static IEnumerable<DateTime> GetDates(IMarketDataStorage storage)
result = StorageHelper.GetDates(storage)
Envoltorio sincronizado para GetDatesAsync.
- storage
- Almacenamiento de datos de mercado.
Devuelve: Fechas disponibles.
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.
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.
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.
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.
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
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
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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
public const string SecurityBackslashSeparator
value = StorageHelper.SecurityBackslashSeparator
El delimitador, reemplazando '\' en el camino para instrumentos con id como USD\EUR. Es igual a '##BS###'.
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###'.
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##'.
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##'.
public const string SecuritySlashSeparator
value = StorageHelper.SecuritySlashSeparator
El delimitador, reemplazando '/' en camino por instrumentos con id como USD/EUR. Es igual a '__@'.
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##'.
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##'.