STOCKSHARPДокументация

DatabaseExporter

StockSharp.Algo.Export

Экспорт в базу данных.

Наследует: BaseExporter

Конструкторы

DatabaseExporter

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

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

Экспорт в базу данных.

dbProvider: IDatabaseProvider
dataType: Информация о типе данных.
connection: Подключение к БД.
priceStep: Минимальный шаг цены.
volumeStep: Минимальный шаг громкости.

Свойства

BatchSize

public int BatchSize { get; set; }

value = databaseExporter.BatchSize
databaseExporter.BatchSize = value

Размер передаваемого пакета данных. По умолчанию 50 элементов.

CheckUnique

public bool CheckUnique { get; set; }

value = databaseExporter.CheckUnique
databaseExporter.CheckUnique = value

Проверить уникальность данных в базе данных. Это влияет на производительность. По умолчанию включен.

DropExisting

public bool DropExisting { get; set; }

value = databaseExporter.DropExisting
databaseExporter.DropExisting = value

Бросьте существующую таблицу перед экспортом. Дефолт отключен.

PriceStep

public decimal? PriceStep { get; }

value = databaseExporter.PriceStep

Минимальный шаг цены.

TableNamePrefix

public string TableNamePrefix { get; set; }

value = databaseExporter.TableNamePrefix
databaseExporter.TableNamePrefix = value

Факультативный пристав для имен таблиц (e.g "SS_").

VolumeStep

public decimal? VolumeStep { get; }

value = databaseExporter.VolumeStep

Минимальный шаг громкости.

Методы

Export

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

result = databaseExporter.Export(values, cancellationToken)

Чтобы экспортировать IndicatorValue асинхронно.

values: Ценности.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать PositionChangeMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать SecurityMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать NewsMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать CandleMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать Level1ChangeMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать BoardMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать BoardStateMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Чтобы экспортировать QuoteChangeMessage асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

ExportOrderLogAsync

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

result = databaseExporter.ExportOrderLogAsync(messages, cancellationToken)

Чтобы экспортировать OrderLog асинхронно.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

ExportTicksAsync

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

result = databaseExporter.ExportTicksAsync(messages, cancellationToken)

Для асинхронного экспорта тиков.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.

ExportTransactionsAsync

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

result = databaseExporter.ExportTransactionsAsync(messages, cancellationToken)

Для асинхронного экспорта транзакций.

messages: Сообщения.
cancellationToken: Токен отмены.

Возвращает: Посчитайте и в последний раз.