Estou fazendo um programa Console
, onde basicamente ele executa esses 4 procedimentos
- Recupera um
IEnumerable<_Url>
- Faz um parsing nessas urls
- Insere no Database
- Marca essa _Url, como lida (processada) assim não processa mais
Porém estou recebendo um erro:
> New transaction is not allowed because there are other threads running in the session.
Meu program console está assim:
private static void Main(string[] args)
{
IEnumerable<Urls> registros = db.UrlsTable.Where(w => w.Lido == false).Take(10);
ExecutaTarefasAsync(registros).Wait();
}
public static async Task ExecutaTarefasAsync(IEnumerable<Urls> registros)
{
var urlTasks = registros.Select((registro, index) =>
{
//parsing html
var modelProduto = ExtraiDados.ParserHtml(registro.Url);
db.Produto.Add(modelProduto);
//save Database
var downloadTask = db.SaveChangesAsync();
//marca url como lida
registro.Lido = true;
db.Entry(registro).State = EntityState.Modified;
db.SaveChangesAsync();
return downloadTask;
});
await Task.WhenAll(urlTasks);
}
Inicialmente estou fazendo com o EntityFramework porque seria a forma mais fácil e depois refatoraria para Dapper ou Ado.Net para máximo desempenho.
Não sei se posso fazer uma 2ª pergunta, mas caso eu faça com Ado.Net eu teria que criar uma função Parallel.ForEach
para fazer os insert ?
Hoje o problema é que eu faço o download das fotos e essa etapa demora mais do que o parsing, por isso quero utilizar o async corretamente para maximizar o processo, até pq são milhares de registros todos os dias.
ExecutaTarefasAsync
possua seu própriodb
, o criando de tal forma que garanta que o método possua sua própria sessão conectada ao banco.