ASP.NET Web API Azure Blob 存储非结构化

Question

我正在构建一个 ASP.NET Web API 项目，该项目需要使用 Azure blob 存储上传 Word 文档。我有一种创建用户配置文件的方法，但不幸的是，我遇到了与 azure blob 存储和上传文档相关的问题。调试时，IFormFile 文档为空，与 azure 的连接也为空。我无法弄清楚断开连接的位置。如果有人知道解决方案，我将不胜感激。下面是我写的代码。

型号

Person Model

public int Id {get; set;}
public string FirstName {get; set;}
public string LastName {get;set;}
public string URL {get;set;}
public string DocName {get;set;}
public string IFormFile[] DocUpload {get;set;}

存储库

public class DocRepo : IDocRepo
{
    private CloudStorageAccount storageAccount = null;
    private CloudBlobContainer cloudBlobContainer = null;

    public IConfiguration _config { get; }

    private readonly ILogger _logger;

    public DocRepo(ILogger logger)
    {
        _logger = logger;
    }


    public void Configure()
    {
        var AzConnectionString = _config["AzConnectionString"];

        if (CloudStorageAccount.TryParse(AzConnectionString, out storageAccount))
        {
            try
            {
                CloudBlobClient cloudBlobClient = storageAccount.CreateCloudBlobClient();

                cloudBlobContainer = cloudBlobClient.GetContainerReference("folder");
                cloudBlobContainer.CreateAsync().GetAwaiter().GetResult();

                BlobContainerPermissions permissions = new BlobContainerPermissions
                {
                    PublicAccess = BlobContainerPublicAccessType.Blob
                };
                cloudBlobContainer.SetPermissionsAsync(permissions).GetAwaiter().GetResult();
            }
            catch (StorageException ex)
            {
                _logger.LogError("Error returned from the service: {0}", ex);
            }
            _logger.LogInformation("Success");
        }
        else
        {
            _logger.LogInformation("No Connection");
        }
    }



    public async Task Upload(IFormFile[] docuFile)
    {
        Person person = new Person();
        person.DocUpload = docuFile;

        List<string> url = new List<string>();
        List<string> docName = new List<string>();

        try
        {
            if (docuFile != null)
            {
                foreach (var file in docuFile)
                {

                    if (file.ContentType == "application/msword")
                    {
                        if (file.Length < 5 * 1400 * 1400)
                        {
                            var parsedContentDisposition = ContentDispositionHeaderValue.Parse(file.ContentDisposition);

                            var filename = parsedContentDisposition.FileName.Trim('"');
                            docName.Add(filename);

                            filename = Guid.NewGuid().ToString() + "-" + filename;

                            CloudBlockBlob cloudBlockBlob = cloudBlobContainer.GetBlockBlobReference(filename);
                            cloudBlockBlob.Properties.ContentType = file.ContentType;
                            await cloudBlockBlob.UploadFromStreamAsync(file.OpenReadStream());

                            url.Add(cloudBlockBlob.Uri.AbsoluteUri);
                        }
                        else
                        {
                            _logger.LogInformation("5 mb max size allowed");
                        }
                    }
                    else
                    {
                        _logger.LogInformation("Only .doc format accepted");
                    }
                }
                person.URL = (urls.Count > 0) ? string.Join(" || ", urls) : null;
                person.DocName = string.Join(" || ", name);
            }
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error uploading");
        }
    }

界面

 public interface IDocRepo
{
    void Configure();
    Task Upload(IFormFile[] doc);
}

人员控制器

[HttpPost]
            public async Task<IActionResult> Create([FromBody] Person person)
            {
                if (ModelState.IsValid)
                {
                    try
                    {
                        _docRepo.CreateConfigure();
                        await _docRepo.Upload(person.DocUpload);
                        _context.Person.Add(person);
                        await _context.SaveChanges();
                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
                return CreatedAtAction("PersonCreated", new { id = person.Id }, person);
            }

Answer 1

我对您的代码做了一些更改，并删除了一些编译错误。 看看这个代码。我能够上传文件（用邮递员测试）。我删除了一些配置代码（直接在代码中使用了连接字符串），但这不应该影响主代码。

人物模型

namespace WebApplication8.Models
{
    public class Person
    {
        public int Id { get; set; }
        public string FirstName { get; set; }
        public string LastName { get; set; }
        public string URL { get; set; }
        public string DocName { get; set; }
        public IList<IFormFile> docs {get;set;}
    }
}

删除请求模型

namespace WebApplication8.Models
{
    public class DeleteRequest
    {
        public string container;
        public IList<string> docs;
    }
}

人员控制器

[Route("api/Person")]
public class PersonController : Controller
{
    private readonly ILogger<PersonController> _logger;
    private readonly IDocRepo _docRepo;

    public PersonController(ILogger<PersonController> logger, IDocRepo docRepo)
    {
        _logger = logger;
        _docRepo = docRepo;
    }

    [HttpPost]
    public async Task<IActionResult> Create([FromForm] Person person)
    {
        if (ModelState.IsValid)
        {
            try
            {
                _docRepo.Configure();
                await _docRepo.Upload(person.docs);
                //_context.Person.Add(person);
                //await _context.SaveChanges();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return Ok();
        }
        else
        {
            return BadRequest();
        }

    }
}

    [HttpDelete]
    public async Task<IActionResult> Delete([FromBody] DeleteRequest deleteRequest)
    {

        if (ModelState.IsValid)
        {
            try
            {
                _docRepo.Configure();
                await _docRepo.Delete(deleteRequest.docs);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return Ok();
        }
        else
        {
            return BadRequest();
        }
    }

IDocRepo 和 DocRepo

public interface IDocRepo
{
    void Configure();
    Task Upload(IList<IFormFile> pdfFiles);
    Task Delete(IList<string> docs);
}

public class DocRepo : IDocRepo
{
    private CloudStorageAccount storageAccount = null;
    private CloudBlobContainer cloudBlobContainer = null;


    private readonly ILogger<DocRepo> _logger;

    public DocRepo(ILogger<DocRepo> logger)
    {
        _logger = logger;
    }


    public void Configure()
    {
        var AzConnectionString = "<<Add your connection string >>";

        if (CloudStorageAccount.TryParse(AzConnectionString, out storageAccount))
        {
            try
            {
                CloudBlobClient cloudBlobClient = storageAccount.CreateCloudBlobClient();
                cloudBlobContainer = cloudBlobClient.GetContainerReference("folder");
                cloudBlobContainer.CreateAsync().GetAwaiter().GetResult();

                BlobContainerPermissions permissions = new BlobContainerPermissions
                {
                    PublicAccess = BlobContainerPublicAccessType.Blob
                };
                cloudBlobContainer.SetPermissionsAsync(permissions).GetAwaiter().GetResult();
            }
            catch (StorageException ex)
            {
                _logger.LogError("Error returned from the service: {0}", ex);
            }
            _logger.LogInformation("Success");
        }
        else
        {
            _logger.LogInformation("No Connection");
        }
    }



    public async Task Upload(IList<IFormFile> docs)
    {
        //Person person = new Person();
        //person.docs = new List<IFormFile>(docs);

        List<string> url = new List<string>();
        List<string> docName = new List<string>();

        try
        {
            if (docs != null)
            {
                foreach (var file in docs)
                {

                    if (file.ContentType == "application/msword")
                    {
                        if (file.Length < 5 * 1400 * 1400)
                        {
                            var parsedContentDisposition = ContentDispositionHeaderValue.Parse(file.ContentDisposition);

                            var filename = parsedContentDisposition.FileName.Trim('"');
                            docName.Add(filename);

                            filename = Guid.NewGuid().ToString() + "-" + filename;

                            CloudBlockBlob cloudBlockBlob = cloudBlobContainer.GetBlockBlobReference(filename);
                            cloudBlockBlob.Properties.ContentType = file.ContentType;
                            await cloudBlockBlob.UploadFromStreamAsync(file.OpenReadStream());

                            url.Add(cloudBlockBlob.Uri.AbsoluteUri);
                        }
                        else
                        {
                            _logger.LogInformation("5 mb max size allowed");
                        }
                    }
                    else
                    {
                        _logger.LogInformation("Only .doc format accepted");
                    }
                }
                //person.URL = (url.Count > 0) ? string.Join(" || ", url) : null;
                //person.DocName = string.Join(" || ", file.);
            }
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error uploading");
        }
    }
}

    public async Task Delete(IList<string> docs)
    {
        foreach (var doc in docs)
        {
            try
            {
                CloudBlockBlob blockBlob = cloudBlobContainer.GetBlockBlobReference(doc);
                await blockBlob.DeleteIfExistsAsync();
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error deleting blob " + doc);
            }
        }
    }

从 Startup.cs 更改了 sn-p

public void ConfigureServices(IServiceCollection services)
{
    services.AddMvc();
    services.AddScoped<IDocRepo, DocRepo>();
}