DatabaseExporter

StockSharp.Algo.Export

データベースへのエクスポート。

コンストラクター

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

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

データベースへのエクスポート。

dbProvider: 担当: 佐藤宏
dataType: データ型情報。
connection: DBへの接続
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: キャンセルトークン。

戻り値: カウントと最後の時間。