DatabaseExporter

DatabaseExporter

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

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

A exportação para a base de dados.

dbProvider

IDatabaseProvider

dataType

Informação do tipo de dados.

connection

A ligação com o DB.

priceStep

Passo mínimo de preço.

volumeStep

Passo de volume mínimo.

BatchSize

public int BatchSize { get; set; }

value = databaseExporter.BatchSize
databaseExporter.BatchSize = value

O tamanho do pacote de dados transmitidos. O padrão é de 50 elementos.

CheckUnique

public bool CheckUnique { get; set; }

value = databaseExporter.CheckUnique
databaseExporter.CheckUnique = value

Para verificar a singularidade dos dados na base de dados. Ele afeta o desempenho. O padrão está habilitado.

DropExisting

public bool DropExisting { get; set; }

value = databaseExporter.DropExisting
databaseExporter.DropExisting = value

Larga a tabela existente antes de exportar. O padrão está desativado.

PriceStep

public decimal? PriceStep { get; }

value = databaseExporter.PriceStep

Passo mínimo de preço.

TableNamePrefix

public string TableNamePrefix { get; set; }

value = databaseExporter.TableNamePrefix
databaseExporter.TableNamePrefix = value

Prefixo opcional para nomes de tabelas (e.g. "SS_").

VolumeStep

public decimal? VolumeStep { get; }

value = databaseExporter.VolumeStep

Passo de volume mínimo.

Export

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

result = databaseExporter.Export(values, cancellationToken)

Para exportar IndicatorValue assíncrona.

values

Valores.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar PositionChangeMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar SecurityMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar NewsMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar CandleMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar Level1ChangeMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar BoardMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar BoardStateMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

Export

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

result = databaseExporter.Export(messages, cancellationToken)

Para exportar QuoteChangeMessage assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

ExportOrderLogAsync

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

result = databaseExporter.ExportOrderLogAsync(messages, cancellationToken)

Para exportar OrderLog assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

ExportTicksAsync

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

result = databaseExporter.ExportTicksAsync(messages, cancellationToken)

Para exportar Ticks assincronicamente.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.

ExportTransactionsAsync

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

result = databaseExporter.ExportTransactionsAsync(messages, cancellationToken)

Para exportar as Transações de forma assíncrona.

messages

Mensagens.

cancellationToken

Inscrição de cancelamento.

Retorna: Conde e da última vez.