StorageHelper

ClearDatesCache

public static void ClearDatesCache(IMarketDataStorageDrive drive)

StorageHelper.ClearDatesCache(drive)

Synchrone Wrapper für CancellationToken.

drive

Marktdatenspeicherantrieb.

Delete

public static void Delete(ISecurityStorage storage, Security security)

StorageHelper.Delete(storage, security)

Synchrone Wrapper für CancellationToken.

storage

Lagerung von Finanzinstrumenten.

security

Finanzinstrument.

Delete

public static void Delete(IMarketDataStorageDrive drive, DateTime date)

StorageHelper.Delete(drive, date)

Synchrone Wrapper für CancellationToken.

drive

Marktdatenspeicherantrieb.

date

Datum, für das alle Daten gelöscht werden.

Delete

public static void Delete(IMarketDataStorage storage, IEnumerable<Message> data)

StorageHelper.Delete(storage, data)

Synchrone Wrapper für CancellationToken.

storage

Marktdatenspeicherung.

data

Marktdaten zu streichen.

Delete

public static void Delete(IMarketDataStorage storage, DateTime date)

StorageHelper.Delete(storage, date)

Synchrone Wrapper für CancellationToken.

storage

Marktdatenspeicherung.

date

Datum, für das alle Daten gelöscht werden.

Delete

public static bool Delete(IMarketDataStorage storage, DateTime? from, DateTime? to)

result = StorageHelper.Delete(storage, from, to)

Um Marktdaten aus dem Speicher für den angegebenen Zeitraum zu löschen.

storage

Marktdatenspeicherung.

from

Die Startzeit für die Datenlöschung. Wenn der Wert nicht angegeben ist, werden die Daten ab dem Datum GetDatesAsync gelöscht.

to

Die Endzeit, bis zu der die Daten gelöscht werden. Wenn der Wert nicht angegeben ist, werden die Daten bis zum Enddatum GetDatesAsync, einschließlich gelöscht.

Rückgabe: wenn Daten gelöscht wurden, sind Daten für den angegebenen Zeitraum nicht vorhanden.

DeleteAsync

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

result = StorageHelper.DeleteAsync(storage, from, to, cancellationToken)

Um Marktdaten aus dem Speicher für den angegebenen Zeitraum zu löschen.

storage

Marktdatenspeicherung.

from

Die Startzeit für die Datenlöschung. Wenn der Wert nicht angegeben ist, werden die Daten ab dem Datum GetDatesAsync gelöscht.

to

Die Endzeit, bis zu der die Daten gelöscht werden. Wenn der Wert nicht angegeben ist, werden die Daten bis zum Enddatum GetDatesAsync, einschließlich gelöscht.

cancellationToken

CancellationToken

Rückgabe: wenn Daten gelöscht wurden, sind Daten für den angegebenen Zeitraum nicht vorhanden.

DeleteBy

public static void DeleteBy(ISecurityStorage storage, SecurityLookupMessage criteria)

StorageHelper.DeleteBy(storage, criteria)

Synchrone Wrapper für CancellationToken.

storage

Lagerung von Finanzinstrumenten.

criteria

Das Kriterium.

DeleteByIdAsync

public static ValueTask DeleteByIdAsync(ISecurityStorage securityStorage, string securityId, CancellationToken cancellationToken)

result = StorageHelper.DeleteByIdAsync(securityStorage, securityId, cancellationToken)

Instrument nach Kennung löschen.

securityStorage

Meta-Info-Speicherung von Finanzinstrumenten.

securityId

Kennung.

cancellationToken

CancellationToken

DeleteByIdAsync

public static ValueTask DeleteByIdAsync(ISecurityStorage securityStorage, SecurityId securityId, CancellationToken cancellationToken)

result = StorageHelper.DeleteByIdAsync(securityStorage, securityId, cancellationToken)

Instrument nach Kennung löschen.

securityStorage

Meta-Info-Speicherung von Finanzinstrumenten.

securityId

Kennung.

cancellationToken

CancellationToken

DeleteRange

public static void DeleteRange(ISecurityStorage storage, IEnumerable<Security> securities)

StorageHelper.DeleteRange(storage, securities)

Synchrone Wrapper für CancellationToken.

storage

Lagerung von Finanzinstrumenten.

securities

Finanzinstrumente.

Delete``1

public static void Delete<TMessage>(IMarketDataStorage<TMessage> storage, IEnumerable<TMessage> data)

StorageHelper.Delete(storage, data)

Synchrone Wrapper für CancellationToken.

storage

Marktdatenspeicherung.

data

Marktdaten zu streichen.

FolderNameToSecurityId

public static string FolderNameToSecurityId(string folderName)

result = StorageHelper.FolderNameToSecurityId(folderName)

Die inverse Konvertierung aus der String-Methode.

folderName

Verzeichnisname.

Rückgabe: Kennung des Finanzinstruments.

GetAvailableDataTypes

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

result = StorageHelper.GetAvailableDataTypes(drive, securityId, format)

Holen Sie sich alle verfügbaren Datentypen.

drive

IMarketDataDrive

securityId

Instrumentenkennung.

format

Formattyp.

Rückgabe: Datentypen.

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)

Um die Kerzen für das angegebene Instrument zu speichern, wird die Speicherung Kerzen aus kleineren Zeitrahmen erstellen, wenn keine ursprünglichen Zeitrahmen vorhanden sind.

provider

Candle Builders Anbieter.

registry

Marktdatenspeicherung.

securityId

Kennung des Finanzinstruments.

timeFrame

Zeitrahmen.

drive

Wenn ein Wert , wird DefaultDrive verwendet.

format

Standardmäßig ist Binary übergeben.

cancellationToken

CancellationToken

Rückgabe: Die Kerzen Lagerung.

GetCandleMessageStorage

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

result = StorageHelper.GetCandleMessageStorage(registry, subscription, drive, format)

Um die Kerzen für das angegebene Instrument zu speichern.

registry

IStorageRegistry.

subscription

Zeichnung.

drive

Lagerung.

format

Formattyp.

Rückgabe: Die Kerzen Lagerung.

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)

Um die Kerzen für das angegebene Instrument zu speichern.

registry

IStorageRegistry

candleMessageType

Die Art der Kerzennachricht.

securityId

Kennung des Finanzinstruments.

arg

Kerzen Arg.

drive

Lagerung.

format

Formattyp.

Rückgabe: Die Kerzen Lagerung.

GetDates

public static IEnumerable<DateTime> GetDates(IMarketDataStorage storage, DateTime? from, DateTime? to)

result = StorageHelper.GetDates(storage, from, to)

Um alle Daten für gespeicherte Marktdaten für den angegebenen Bereich zu erhalten.

storage

Marktdatenspeicherung.

from

Die Range Startzeit. Wenn der Wert nicht angegeben ist, werden Daten ab dem Startdatum GetDatesAsync geladen.

to

Die Endzeit des Bereichs. Wenn der Wert nicht angegeben ist, werden die Daten bis zum Enddatum GetDatesAsync, einschließlich geladen.

Rückgabe: Alle verfügbaren Daten innerhalb des Bereichs.

GetDates

public static IEnumerable<DateTime> GetDates(IMarketDataStorageDrive drive)

result = StorageHelper.GetDates(drive)

Synchrone Wrapper für GetDatesAsync.

drive

Marktdatenspeicherantrieb.

Rückgabe: Verfügbare Termine.

GetDates

public static IEnumerable<DateTime> GetDates(IMarketDataStorage storage)

result = StorageHelper.GetDates(storage)

Synchrone Wrapper für GetDatesAsync.

storage

Marktdatenspeicherung.

Rückgabe: Verfügbare Termine.

GetDatesAsync

public static IAsyncEnumerable<DateTime> GetDatesAsync(IMarketDataStorage storage, DateTime? from, DateTime? to)

result = StorageHelper.GetDatesAsync(storage, from, to)

Um alle Daten für gespeicherte Marktdaten für den angegebenen Bereich zu erhalten.

storage

Marktdatenspeicherung.

from

Die Range Startzeit. Wenn der Wert nicht angegeben ist, werden Daten ab dem Startdatum GetDatesAsync geladen.

to

Die Endzeit des Bereichs. Wenn der Wert nicht angegeben ist, werden die Daten bis zum Enddatum GetDatesAsync, einschließlich geladen.

Rückgabe: Alle verfügbaren Daten innerhalb des Bereichs.

GetExecutionMessageStorage

public static IMarketDataStorage<ExecutionMessage> GetExecutionMessageStorage(IStorageRegistry registry, SecurityId securityId, ExecutionTypes type, IMarketDataDrive drive, StorageFormats format)

result = StorageHelper.GetExecutionMessageStorage(registry, securityId, type, drive, format)

Um den ExecutionMessage @ Speicher für das angegebene Instrument zu erhalten.

registry

IStorageRegistry

securityId

Kennung des Finanzinstruments.

type

Datentyp, über den Informationen in ExecutionMessage enthalten sind.

drive

Lagerung.

format

Formattyp.

Rückgabe: Der ExecutionMessage Storage.

GetFromDate

public static DateTime? GetFromDate(IMarketDataStorage storage)

result = StorageHelper.GetFromDate(storage)

Um das Startdatum für Marktdaten zu erhalten, die im Speicher gespeichert sind.

storage

Marktdatenspeicherung.

Rückgabe: Startdatum. Wenn der Wert nicht initialisiert ist, ist der Speicher leer.

GetMetaInfo

public static IMarketDataMetaInfo GetMetaInfo(IMarketDataStorage storage, DateTime date)

result = StorageHelper.GetMetaInfo(storage, date)

Synchrone Wrapper für CancellationToken.

storage

Marktdatenspeicherung.

date

Datum, für das Meta-Informationen zu Daten zu erhalten sind.

Rückgabe: Meta-Informationen zu Daten. Wenn es kein solches Datum in der Geschichte gibt, werden sie zurückgegeben.

GetRange

public static IRange<DateTime> GetRange(IMarketDataStorage storage, DateTime? from, DateTime? to)

result = StorageHelper.GetRange(storage, from, to)

Erhalten Sie einen verfügbaren Datumsbereich für den angegebenen Speicher.

storage

Lagerung.

from

Das erste Datum, ab dem Sie Daten erhalten müssen.

to

Das endgültige Datum, bis zu dem Sie Daten erhalten müssen.

Rückgabe: Datumsbereich

GetRangeAsync

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

result = StorageHelper.GetRangeAsync(storage, from, to, cancellationToken)

Erhalten Sie einen verfügbaren Datumsbereich für den angegebenen Speicher.

storage

Lagerung.

from

Das erste Datum, ab dem Sie Daten erhalten müssen.

to

Das endgültige Datum, bis zu dem Sie Daten erhalten müssen.

cancellationToken

CancellationToken

Rückgabe: Datumsbereich

GetSnapshotStorage

public static ISnapshotStorage GetSnapshotStorage(ISnapshotRegistry registry, Type dataType, object arg)

result = StorageHelper.GetSnapshotStorage(registry, dataType, arg)

Um den Snapshot-Speicher zu erhalten.

registry

Snapshot Storage Registry.

dataType

Art der Marktdaten.

arg

Der mit dem Typ verbundene Parameter, z. B. Kerze arg.

Rückgabe: Der Snapshot Storage.

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)

Um die Marktdatenspeicherung zu erhalten.

registry

IStorageRegistry

securityId

Kennung des Finanzinstruments.

dataType

Art der Marktdaten.

arg

Der mit dem Typ verbundene Parameter, z. B. Kerze arg.

drive

Lagerung.

format

Formattyp.

Rückgabe: Marktdatenspeicherung.

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)

Um die Marktdatenspeicherung zu erhalten.

registry

IStorageRegistry

security

Finanzinstrument.

dataType

Art der Marktdaten.

arg

Der mit dem Typ verbundene Parameter, z. B. Kerze arg.

drive

Wenn ein Wert , wird DefaultDrive verwendet.

format

Standardmäßig ist Binary übergeben.

Rückgabe: Marktdatenspeicherung.

GetStorage

public static IMarketDataStorage GetStorage(IStorageRegistry registry, Security security, DataType dataType, IMarketDataDrive drive, StorageFormats format)

result = StorageHelper.GetStorage(registry, security, dataType, drive, format)

Um die Marktdatenspeicherung zu erhalten.

registry

Marktdatenspeicherung.

security

Finanzinstrument.

dataType

Datenart-Info.

drive

Wenn ein Wert , wird DefaultDrive verwendet.

format

Standardmäßig ist Binary übergeben.

Rückgabe: Marktdatenspeicherung.

GetTimeFrameCandleMessageStorage

public static IMarketDataStorage<CandleMessage> GetTimeFrameCandleMessageStorage(IStorageRegistry registry, SecurityId securityId, TimeSpan arg, IMarketDataDrive drive, StorageFormats format)

result = StorageHelper.GetTimeFrameCandleMessageStorage(registry, securityId, arg, drive, format)

Um die Kerzen für das angegebene Instrument zu speichern.

registry

IStorageRegistry.

securityId

Kennung des Finanzinstruments.

arg

Kerzen Arg.

drive

Lagerung.

format

Formattyp.

Rückgabe: Die Kerzen Lagerung.

GetToDate

public static DateTime? GetToDate(IMarketDataStorage storage)

result = StorageHelper.GetToDate(storage)

Um das Enddatum für Marktdaten zu erhalten, die im Speicher gespeichert sind.

storage

Marktdatenspeicherung.

Rückgabe: Das Enddatum: Wenn der Wert nicht initialisiert wird, ist der Speicher leer.

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)

Synchrone Wrapper für DateTime.

storage

Marktdatenspeicherung.

date

Datum, für das die Daten geladen werden.

Rückgabe: Daten. Wenn keine Daten vorhanden sind, wird der leere Satz zurückgegeben.

LoadAsync``1

public static IAsyncEnumerable<TMessage> LoadAsync<TMessage>(IMarketDataStorage<TMessage> storage, DateTime? from, DateTime? to)

result = StorageHelper.LoadAsync(storage, from, to)

Erstellen Sie einen iterativen Loader von Marktdaten für den Zeitbereich.

storage

Marktdatenspeicherung.

from

Der Startzeitpunkt für das Laden von Daten. Wenn der Wert nicht angegeben ist, werden Daten ab der Startzeit GetDatesAsync geladen.

to

Die Endzeit für das Laden von Daten. Wenn der Wert nicht angegeben ist, werden die Daten bis zum GetDatesAsync @ Datum geladen.

Rückgabe: Der iterative Loader von Marktdaten.

LoadMessages

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

result = StorageHelper.LoadMessages(settings, candleBuilderProvider, subscription, newOutMessage)

Lademeldungen.

settings

Speichereinstellungen.

candleBuilderProvider

Candle Builders Anbieter.

subscription

Marktdatennachricht (Verwendung als Abonnement/Abonnement im ausgehenden Fall, Bestätigungsereignis im eingehenden Fall).

newOutMessage

Neues Nachrichtenereignis.

Rückgabe: Letztes Datum.

LoadMessagesAsync

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

result = StorageHelper.LoadMessagesAsync(settings, candleBuilderProvider, subscription, context, cancellationToken)

Laden Sie Historienmeldungen aus dem Speicher als async-Stream.

settings

Speichereinstellungen.

candleBuilderProvider

Candle Builders Anbieter.

subscription

Marktdatennachricht (Verwendung als Abonnement/Abonnement im ausgehenden Fall, Bestätigungsereignis im eingehenden Fall).

context

Kontext, der nach der Enumeration mit Lastergebnis-Metadaten gefüllt wird.

cancellationToken

Löschungszeichen.

Rückgabe: Async-Stream von Nachrichten.

LoadStream

public static Stream LoadStream(IMarketDataStorageDrive drive, DateTime date, bool readOnly)

result = StorageHelper.LoadStream(drive, date, readOnly)

Synchrone Wrapper für CancellationToken.

drive

Marktdatenspeicherantrieb.

date

Datum, für das die Daten geladen werden.

readOnly

Streamen Sie nur im Lesemodus.

Rückgabe: Daten im Format StockSharp Storage. Wenn keine Daten vorhanden sind, wird Null zurückgegeben.

Load``1

public static IEnumerable<TMessage> Load<TMessage>(IMarketDataStorage<TMessage> storage, DateTime date)

result = StorageHelper.Load(storage, date)

Synchrone Wrapper für DateTime.

storage

Marktdatenspeicherung.

date

Datum, für das die Daten geladen werden.

Rückgabe: Daten. Wenn keine Daten vorhanden sind, wird der leere Satz zurückgegeben.

Load``1

public static IEnumerable<TMessage> Load<TMessage>(IMarketDataStorage<TMessage> storage, DateTime? from, DateTime? to)

result = StorageHelper.Load(storage, from, to)

Erstellen Sie einen iterativen Loader von Marktdaten für den Zeitbereich.

storage

Marktdatenspeicherung.

from

Der Startzeitpunkt für das Laden von Daten. Wenn der Wert nicht angegeben ist, werden Daten ab der Startzeit GetDatesAsync geladen.

to

Die Endzeit für das Laden von Daten. Wenn der Wert nicht angegeben ist, werden die Daten bis zum GetDatesAsync @ Datum geladen.

Rückgabe: Der iterative Loader von Marktdaten.

Save

public static int Save(IMarketDataStorage storage, IEnumerable<Message> data)

result = StorageHelper.Save(storage, data)

Synchrone Wrapper für CancellationToken.

storage

Marktdatenspeicherung.

data

Marktdaten.

Rückgabe: Anzahl der gespeicherten Daten.

Save

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

StorageHelper.Save(storage, security, forced)

Synchrone Wrapper für CancellationToken.

storage

Lagerung von Finanzinstrumenten.

security

Finanzinstrument.

forced

Erzwungene Aktualisierung.

SaveStream

public static void SaveStream(IMarketDataStorageDrive drive, DateTime date, Stream stream)

StorageHelper.SaveStream(drive, date, stream)

Synchrone Wrapper für CancellationToken.

drive

Marktdatenspeicherantrieb.

date

Datum, für das die Daten gespeichert werden.

stream

Daten im Format von StockSharp Speicher.

Save``1

public static int Save<TMessage>(IMarketDataStorage<TMessage> storage, IEnumerable<TMessage> data)

result = StorageHelper.Save(storage, data)

Synchrone Wrapper für CancellationToken.

storage

Marktdatenspeicherung.

data

Marktdaten.

Rückgabe: Anzahl der gespeicherten Daten.

SecurityIdToFolderName

public static string SecurityIdToFolderName(string id)

result = StorageHelper.SecurityIdToFolderName(id)

Um die Instrumentenkennung in den Ordnernamen umzuwandeln und reservierte Symbole zu ersetzen.

id

Kennung des Finanzinstruments.

Rückgabe: Verzeichnisname.

SetAdapter``1

public static bool SetAdapter<TKey>(IMappingMessageAdapterProvider<TKey> provider, TKey key, IMessageAdapter adapter)

result = StorageHelper.SetAdapter(provider, key, adapter)

Verbinden Sie sich mit Adapter.

provider

Provider-Schnittstelle des Message Adapters.

key

Schlüssel.

adapter

Adapter.

Rückgabe: wenn die Assoziation erfolgreich geändert wird, andernfalls.

SecurityBackslashSeparator

public const string SecurityBackslashSeparator

value = StorageHelper.SecurityBackslashSeparator

Der Trennzeichen, das "\\" im Pfad für Instrumente mit einer ID wie USD\\EUR ersetzt. Ist gleich "##BS##".

SecurityColonSeparator

public const string SecurityColonSeparator

value = StorageHelper.SecurityColonSeparator

Der Trennzeichen, der ':' im Pfad für Instrumente mit id wie AA-CA:SPB@SPBEX ersetzt. Ist gleich '##COLON##'.

SecurityFirstDot

public const string SecurityFirstDot

value = StorageHelper.SecurityFirstDot

Der Trennzeichen, das erste '.' im Pfad für Instrumente mit id wie .AA-CA@SPBEX ersetzt. Ist gleich '##DOT##'.

SecurityQuestionSeparator

public const string SecurityQuestionSeparator

value = StorageHelper.SecurityQuestionSeparator

Der Trennzeichen, das '?' im Pfad für Instrumente mit id wie AA-CA?SPB@SPBEX ersetzt. Ist gleich '##QSTN##'.

SecuritySlashSeparator

public const string SecuritySlashSeparator

value = StorageHelper.SecuritySlashSeparator

Der Trennzeichen, ersetzt '/' im Pfad für Instrumente mit ID wie USD/EUR. Ist gleich '__'.

SecurityStarSeparator

public const string SecurityStarSeparator

value = StorageHelper.SecurityStarSeparator

Der Trennzeichen, das '*' im Pfad für Instrumente durch eine ID wie C.BPO-*@CANADIAN ersetzt. Ist gleich '##STAR##'.

SecurityVerticalBarSeparator

public const string SecurityVerticalBarSeparator

value = StorageHelper.SecurityVerticalBarSeparator

Der Trennzeichen, der im Pfad für Instrumente mit id wie AA-CA|SPB@SPBEX "|" ersetzt. Ist gleich "##VBAR##".