通过Web API ASP.NET Framework Web应用程序C#将图像/文件上传到Blob Azure

如何解决通过Web API ASP.NET Framework Web应用程序C#将图像/文件上传到Blob Azure

在尝试将图片上传到blob时使用邮递员测试api时获得http 400:

 [Route("~/api/myAPI/testapi")]
 [HttpPost]
 public async Task<HttpResponseMessage> testapi()
 {
     String strorageconn = System.Configuration.ConfigurationManager.AppSettings.Get("MyBlobStorageConnectionString");
     Dictionary<string,object> dict = new Dictionary<string,object>(); 

     try  
     {  
         // Create a CloudStorageAccount object using account name and key.
         // The account name should be just the name of a Storage Account,not a URI,and 
         // not including the suffix. The key should be a base-64 encoded string that you
         // can acquire from the portal,or from the management plane.
         // This will have full permissions to all operations on the account.
        // StorageCredentials storageCredentials = new StorageCredentials(myAccountName,myAccountKey);
         //CloudStorageAccount cloudStorageAccount = new CloudStorageAccount(storageCredentials,useHttps: true);
         // Parse the connection string and return a reference to the storage account.
         CloudStorageAccount storageAccount = CloudStorageAccount.Parse(strorageconn);
            
         // If the connection string is valid,proceed with operations against Blob
         // storage here.
         // ADD OTHER OPERATIONS HERE
         // Create the CloudBlobClient that represents the 
         // Blob storage endpoint for the storage account.
         CloudBlobClient cloudBlobClient = storageAccount.CreateCloudBlobClient();
         // Create a container called 'quickstartblobs' and 
         // append a GUID value to it to make the name unique.
         CloudBlobContainer cloudBlobContainer = cloudBlobClient.GetContainerReference("images"); 
         //"quickstartblobs" + Guid.NewGuid().ToString());
         await cloudBlobContainer.CreateAsync();
         if (cloudBlobContainer.CreateIfNotExists())
         {
             cloudBlobContainer.SetPermissions(
                 new BlobContainerPermissions
                 {
                     PublicAccess = BlobContainerPublicAccessType.Blob
                 });
         }
         // Set the permissions so the blobs are public.
        /* BlobContainerPermissions permissions = new BlobContainerPermissions
         {
             PublicAccess = BlobContainerPublicAccessType.Blob
         };
         await cloudBlobContainer.SetPermissionsAsync(permissions); */
            
             // Create a CloudBlobClient object from the storage account.
             // This object is the root object for all operations on the 
             // blob service for this particular account.
             //CloudBlobClient blobClient = cloudStorageAccount.CreateCloudBlobClient();
             var httpRequest = HttpContext.Current.Request;         
             foreach (string file in httpRequest.Files)  
             {  
                 HttpResponseMessage response = Request.CreateResponse(HttpStatusCode.Created);  

                 var postedFile = httpRequest.Files[file]; 
                 // Get a reference to a CloudBlobContainer object in this account. 
                 // This object can be used to create the container on the service,// list blobs,delete the container,etc. This operation does not make a 
                 // call to the Azure Storage service.  It neither creates the container 
                 // on the service,nor validates its existence.
                 string imageName = "images" +serverTime.Year.ToString() + serverTime.Month.ToString() + serverTime.Day.ToString() + 
                                             serverTime.Hour.ToString() + serverTime.Minute.ToString() + serverTime.Second.ToString () 
                                             + postedFile.FileName.ToLower();
                 //CloudBlobContainer container = blobClient.GetContainerReference(imageName.ToLower());
                 /*if(await container.CreateIfNotExistsAsync())  
                 {  
                     await container.SetPermissionsAsync(  
                         new BlobContainerPermissions {  
                             PublicAccess = BlobContainerPublicAccessType.Blob  
                         }  
                         );  
                 }  */

                 if (postedFile != null && postedFile.ContentLength > 0)  
                 {  

                     int MaxContentLength = 1024 * 1024 * 1; //Size = 1 MB  

                     IList<string> AllowedFileExtensions = new List<string> { ".jpg",".gif",".png" };  
                     var ext = postedFile.FileName.Substring(postedFile.FileName.LastIndexOf('.'));  
                     var extension = ext.ToLower();  
                     if (!AllowedFileExtensions.Contains(extension))  
                     {  

                         var message = string.Format("Please Upload image of type .jpg,.gif,.png.");  

                         dict.Add("error",message);  
                         return Request.CreateResponse(HttpStatusCode.BadRequest,dict);  
                     }  
                     else if (postedFile.ContentLength > MaxContentLength)  
                     {  

                         var message = string.Format("Please Upload a file upto 1 mb.");  

                         dict.Add("error",dict);  
                     }  
                     else  
                     {  

                         

                         var filePath = HttpContext.Current.Server.MapPath("~/imagesfiles/uploads" + postedFile.FileName.ToLower() + extension.ToLower());  
                        
                         postedFile.SaveAs(filePath);  
                         //CloudBlockBlob cloudBlockBlob = container.GetBlockBlobReference(imageName);  
                         // Get a reference to the blob address,then upload the file to the blob.
                         // Use the value of localFileName for the blob name.
                         CloudBlockBlob cloudBlockBlob = cloudBlobContainer.GetBlockBlobReference(imageName.ToLower());
                        
                          // create a blob in container and upload image bytes to it
                         //var blob =container.GetBlobReference(postedFile.FileName);
                         await cloudBlockBlob.UploadFromFileAsync(postedFile.FileName);
                         //await cloudBlockBlob.UploadFromFileAsync(filePath); 

                     }  
                 }
                 var message1 = string.Format("Image Updated Successfully.");
                 return Request.CreateErrorResponse(HttpStatusCode.Created,message1); ;
             }
            
           
             var res = string.Format("Please Upload a image.");
             dict.Add("error",res);
             return Request.CreateResponse(HttpStatusCode.NotFound,dict);
            
     }  
     catch (Exception ex)  
     {
         HttpResponseMessage response2 = Request.CreateResponse(HttpStatusCode.BadRequest,ex.InnerException.ToString());
         return response2;
     }  
 }

邮递员的回复:

"System.Net.WebException: The remote server returned an error: (400) Bad Request.\r\n at Microsoft.Azure.Storage.Shared.Protocol.HttpResponseParsers.ProcessExpectedStatusCodeNoException[T](HttpStatusCode expectedStatusCode,HttpStatusCode actualStatusCode,T retVal,StorageCommandBase`1 cmd,Exception ex)\r\n at Microsoft.Azure.Storage.Blob.CloudBlobContainer.<>c_DisplayClass149_0.<CreateContainerImpl>b_2(RESTCommand`1 cmd,HttpWebResponse resp,Exception ex,OperationContext ctx)\r\n at Microsoft.Azure.Storage.Core.Executor.Executor.EndGetResponse[T](IAsyncResult getResponseResult)"

解决方法

感谢彭美拉(Pamela Peng),我得以面对不同的异常并找到了问题。

第一个问题是版本,因此我更改为Visual Studio 2019,必须添加正确的参考。而另一个问题在代码中,所以我用:

                        else
                        {
                            CloudBlockBlob cloudBlockBlob = cloudBlobContainer.GetBlockBlobReference(imageName);
                            cloudBlockBlob.Properties.ContentType = postedFile.ContentType;
                            await cloudBlockBlob.UploadFromStreamAsync(postedFile.InputStream);
                        } 
,

不确定为什么它不起作用,代码看起来正确。在许多情况下都会发生此错误。

  1. 如果您请求的容器名称无效,将导致您收到(400)错误的请求。它有一些关于容器名称的limitations,因此请检查您的字符串。

  2. 如果Blob存储模拟器无法启动,它将返回400 Bad Request。参见here

  3. 如果存储库和存储仿真器的版本不同步,它还将返回400 Bad Request,请参见here

  4. 最后,您的存储位置可能很重要,请参阅here

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)&gt; insert overwrite table dwd_trade_cart_add_inc &gt; select data.id, &gt; data.user_id, &gt; data.course_id, &gt; date_format(
错误1 hive (edu)&gt; insert into huanhuan values(1,&#39;haoge&#39;); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive&gt; show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 &lt;configuration&gt; &lt;property&gt; &lt;name&gt;yarn.nodemanager.res