在后台 Web Api 中运行存储过程

Question

在我的 Web Api 应用程序中，我需要在这个主题中执行类似的操作：Best way to run a background task in ASP.Net web app and also get feedback? 在应用程序中，用户可以上传一个 excel 文件，然后将其数据导入数据库中的表。一切正常，但导入过程可能需要很长时间（大约 20 分钟，如果 excel 有很多行），并且当进程启动时，页面被阻止，用户必须一直等待。我需要在后台运行这个导入过程。

我有一个使用这种 POST 方法的控制器：

[HttpPost]
public async Task<IHttpActionResult> ImportFile(int procId, int fileId)
{
    string importErrorMessage = String.Empty;

    // Get excel file and read it
    string path = FilePath(fileId);
    DataTable table = GetTable(path);

    // Add record for start process in table Logs
    using (var transaction = db.Database.BeginTransaction()))
    {
        try
        {
            db.uspAddLog(fileId, "Process Started", "The process is started");
            transaction.Commit();
        }
        catch (Exception e)
        {
            transaction.Rollback();
            importErrorMessage = e.Message;
            return BadRequest(importErrorMessage);
        }
    }

    //Using myHelper start a store procedure, which import data from excel file
    //The procedure also add record in table Logs when it is finished
    using (myHelper helper = new myHelper())
    helper.StartImport(procId, fileId, table, ref importErrorMessage);

        if (!String.IsNullOrEmpty(importErrorMessage))
        return BadRequest(importErrorMessage);

    return Ok(true);
}

我还有一个 GET 方法，它返回有关文件及其进程的信息

[HttpGet]
[ResponseType(typeof(FileDTO))]
public IQueryable<FileDTO> GetFiles(int procId)
{
    return db.LeadProcessControl.Where(a => a.ProcessID == procId)
                                .Project().To<FileDTO>();
}

它像这样返回 JSON：

{
  FileName = name.xlsx
  FileID = 23
  ProcessID = 11
  Status = Started
}

此方法适用于 GRID

File name | Status | Button to run import | Button to delete file

这个Status 来自表Logs 并在FileDTO 中放置了最后一个值，例如，如果我上传文件status 将是“文件上传”当我运行导入status 将是“已开始”，当它完成时status 将是“完成”。但是现在页面在导入过程运行时被锁定，所以状态总是“完成”。

所以我需要在后台运行程序，并且 GET 方法应该返回新的Status 如果它已被更改。有什么建议吗？

Answer 1

向方法添加异步不会使您的方法调用异步。它只是表明正在处理当前请求的线程可以在等待某些网络/磁盘 IO 时被重用于处理其他请求。当客户端调用此方法时，它只会在方法完成后得到响应。换句话说，异步完全是服务器端的事情，与客户端调用无关。您需要在单独的线程中启动长时间运行的进程，如下所示。但最佳做法是不要将 Web 应用程序用于如此长时间运行的处理，而是在单独的 Windows 服务中进行长时间处理。

[HttpPost]
    public async Task<IHttpActionResult> ImportFile(int procId, int fileId)
{
string importErrorMessage = String.Empty;

// Get excel file and read it
string path = FilePath(fileId);
DataTable table = GetTable(path);

// Add record for start process in table Logs
using (var transaction = db.Database.BeginTransaction()))
{
    try
    {
        db.uspAddLog(fileId, "Process Started", "The process is started");
        transaction.Commit();
    }
    catch (Exception e)
    {
        transaction.Rollback();
        importErrorMessage = e.Message;
        return BadRequest(importErrorMessage);
    }
}

         //Start long running process in new thread
         Task.Factory.StartNew(()=>{

         using (myHelper helper = new myHelper())
        {
           helper.StartImport(procId, fileId, table, ref importErrorMessage);

          //** As this code is running background thread you cannot return anything here. You just need to store status in database. 

         //if (!String.IsNullOrEmpty(importErrorMessage))
         //return BadRequest(importErrorMessage);
       }

        });

//You always return ok to indicate background process started
return Ok(true);
}