Cassanda пакетная вставка с использованием DataStax C# драйвера

Question

Я строю приложение для измерения баз данных NoSQL, и у меня есть проблема с вставкой большого количества данных в базу данных Cassandra.

Когда я пытаюсь вставить более 1000 записей с использованием DataStax C#, я получаю сообщение об ошибке AggregateException.

Это моя модель данных:

public Guid Id { get; set; } 
    public string Title { get; set; } 
    public string Description { get; set; } 
    public int Year { get; set; } 
    public string Genres { get; set; } 
    public int Rating { get; set; } 
    public string OriginalLanguage { get; set; } 
    public string ProductionCountry { get; set; } 
    public int VotingsNumber { get; set; } 

И это мой код:

private string InsertData(ISession session, List<Movie> moviesList) 
{ 
     var table = session.GetTable<Movie>(); 
     table.CreateIfNotExists(); 

     var batch = session.CreateBatch(); 
     foreach (var record in moviesList) 
     { 
      batch.Append(table.Insert(record)); 
     } 

     Stopwatch watch = new Stopwatch(); 

     watch.Start(); 
     batch.Execute(); 
     watch.Stop(); 

     return watch.ElapsedMilliseconds.ToString(); 
} 

Может кто-нибудь объяснить мне, что Я делаю не так? Спасибо, П.

Answer 1

Пакетные заявления не maded для массовой загрузки в Кассандре, в C# faq Datastax явно рекомендуют иметь размер партии в порядке десятков.

Если вы хотите вставить много данных в свой случай, вы должны regular or async statements сделать это.