Estou tentando criar diversas task (async) elas irão executar a seguinte lógica:
- Fazer o Parse de um Html com base em uma url recebida com o HtmlAgilityPack
- Retornar uma model produto após o parse
- Inserir o Produto no database
- Fazer download das imagens do produto
- Marcar url como lida
os itens 1 e 4, principalmente o 4 demoram por causa da velocidade do link da internet, então por isso eles devem ser async. Porém estou com dificuldades, todo meu código roda, porém de forma sincrona.
private static void Main(string[] args)
{
IEnumerable<UrlsProdutos> registros = db.UrlsTable.Where(w => w.Lido == false).Take(1000);
ExecutaTarefasAsync(registros).Wait();
}
public static async Task ExecutaTarefasAsync(IEnumerable<UrlsProdutos> registros)
{
var urlTasks = registros.Select((registro, index) =>
{
Task downloadTask = default(Task);
//parsing html
var produtoTask = ExtraiDados.ParseHtml(registro.Url);
if (produtoTask.IsCompleted)
{
var produto = produtoTask.Result;
//aqui faço um insert com Dapper
downloadTask = InsertAdo.InsertAdoStpAsync(produto);
}
//marca url como lida, igual ao insert do produto
InsertAdo.MarcaComoLido(registro.UrlProdutoId);
Output(index);
return downloadTask;
});
await Task.WhenAll(urlTasks);
}
public static void Output(int id)
{
Console.WriteLine($"Executando {id.ToString()}");
}
O insert fiz um fixo só para testar
public static async Task InsertAdoStpAsync(Imovel imovel)
{
var stringConnection = db.Database.Connection.ConnectionString;
var con = new SqlConnection(stringConnection);
var sqlQuery = "insert tblProdutos...etc..etc"
con.ExecuteAsync(sqlQuery);
}
Não sei se cada função deve ser async. ou se eu poderia selecionar tipo o Download e o parse ser async..
O meu sistema de download de fotos async funciona perfeitamente.
public static async Task DownloadData(IEnumerable<FotosProdutos> urls)
{
var urlTasks = urls.Select((url, index) =>
{
var filename = "";
var wc = new WebClient();
string path = "C:\teste\" + url.FileName;
var downloadTask = wc.DownloadFileTaskAsync(new Uri(url), path);
return downloadTask;
});
await Task.WhenAll(urlTasks);
}
Preciso de ajuda para fazer e entender como o ExecutaTarefasAsync ser realmente async igual ao fotos que hj nem consegui ainda incorporar nesse projeto.
OBS: Não sei se o download das fotos faço lá no parse ou se coloco nessa task.