CsvImporter

CsvImporter

public CsvImporter(DataType dataType, IEnumerable<FieldMapping> fields, ISecurityStorage securityStorage, IExchangeInfoProvider exchangeInfoProvider, Func<SecurityId, IMarketDataStorage> getStorage)

csvImporter = CsvImporter(dataType, fields, securityStorage, exchangeInfoProvider, getStorage)

CSV形式のテキストファイルから、ストレージへのメッセージのインポート

dataType

データ型情報。

fields

フィールドのインポート

securityStorage

金融商品メタ情報ストレージ。

exchangeInfoProvider

取引所および取引銀行のプロバイダ。

getStorage

SecurityId で IMarketDataStorage を取得する機能.

UpdateDuplicateSecurities

public bool UpdateDuplicateSecurities { get; set; }

value = csvImporter.UpdateDuplicateSecurities
csvImporter.UpdateDuplicateSecurities = value

既に存在している場合は、重複した金融商品を更新します。

Import

public ValueTask<ValueTuple<int, DateTime?>> Import(Stream stream, Action<int> updateProgress, CancellationToken cancellationToken)

result = csvImporter.Import(stream, updateProgress, cancellationToken)

CSVファイルからインポートします。

stream

ファイルのストリーム。

updateProgress

進捗通知。

cancellationToken

担当: 佐藤 宏

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

SecurityUpdated

public event Action<Security, bool> SecurityUpdated

csvImporter.SecurityUpdated += handler

金融商品更新イベント