DatabaseExporter

DatabaseExporter

public DatabaseExporter(IDatabaseProvider dbProvider, DataType dataType, DatabaseConnectionPair connection, decimal? priceStep, decimal? volumeStep)

databaseExporter = DatabaseExporter(dbProvider, dataType, connection, priceStep, volumeStep)

Export in die Datenbank.

dbProvider

IDatabaseProvider

dataType

Datenart-Info.

connection

Die Verbindung zur DB.

priceStep

Mindestpreisstufe.

volumeStep

Mindestvolumenstufe.

BatchSize

public int BatchSize { get; set; }

value = databaseExporter.BatchSize
databaseExporter.BatchSize = value

Die Größe des übertragenen Datenpakets. Die Vorgabe ist 50 Elemente.

CheckUnique

public bool CheckUnique { get; set; }

value = databaseExporter.CheckUnique
databaseExporter.CheckUnique = value

Um die Eindeutigkeit der Daten in der Datenbank zu überprüfen. Sie beeinflussen die Leistung. Der Standard ist aktiviert.

DropExisting

public bool DropExisting { get; set; }

value = databaseExporter.DropExisting
databaseExporter.DropExisting = value

Vor dem Export vorhandene Tabelle ablegen.

PriceStep

public decimal? PriceStep { get; }

value = databaseExporter.PriceStep

Mindestpreisstufe.

TableNamePrefix

public string TableNamePrefix { get; set; }

value = databaseExporter.TableNamePrefix
databaseExporter.TableNamePrefix = value

Optionales Präfix für Tabellennamen (e.g. "SS_").

VolumeStep

public decimal? VolumeStep { get; }

value = databaseExporter.VolumeStep

Mindestvolumenstufe.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<IndicatorValue> values, CancellationToken cancellationToken)

result = databaseExporter.Export(values, cancellationToken)

Um IndicatorValue asynchron zu exportieren.

values

Werte.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<PositionChangeMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um PositionChangeMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<SecurityMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um SecurityMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<NewsMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um NewsMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<CandleMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um CandleMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<Level1ChangeMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um Level1ChangeMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<BoardMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um BoardMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<BoardStateMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um BoardStateMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

Export

protected override Task<ValueTuple<int, DateTime?>> Export(IAsyncEnumerable<QuoteChangeMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.Export(messages, cancellationToken)

Um QuoteChangeMessage asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

ExportOrderLogAsync

protected override Task<ValueTuple<int, DateTime?>> ExportOrderLogAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.ExportOrderLogAsync(messages, cancellationToken)

Um OrderLog asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

ExportTicksAsync

protected override Task<ValueTuple<int, DateTime?>> ExportTicksAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.ExportTicksAsync(messages, cancellationToken)

Um Ticks asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.

ExportTransactionsAsync

protected override Task<ValueTuple<int, DateTime?>> ExportTransactionsAsync(IAsyncEnumerable<ExecutionMessage> messages, CancellationToken cancellationToken)

result = databaseExporter.ExportTransactionsAsync(messages, cancellationToken)

Um Transaktionen asynchron zu exportieren.

messages

Nachrichten.

cancellationToken

Löschungszeichen.

Rückgabe: Zählen und letztes Mal.