使用Azure函数下载并存储文件到Azure。

Question

使用Azure函数下载并存储文件到Azure。

4

我想从某些第三方服务器下载文件并将其存储在Azure Storage中。但是我想使用Azure function执行此过程。以下是我想要实现的步骤：

创建Azure(HTTP触发器启用)函数，该函数将由WebHook使用的第三方服务器执行。
使用C＃中的“Webclient”使用Webhook给定的下载URL下载文件内容。

直接将文件内容存储到Azure Storage中。

   
    Task.Run(() =>
    {
    using (var webClient = new WebClient())
    {
        webClient.Headers.Add(HttpRequestHeader.Authorization, string.Format("Bearer {0}", {下载令牌}));
        webClient.Headers.Add(HttpRequestHeader.ContentType, "application/json");
        webClient.DownloadFileAsync("https://www.server.com/file1.mp4", {此处我想将文件存储到Azure Storage中});
        }
        });

- Dharmesh Solanki

您可以将文件放置在httptrigger的请求正文中，然后创建一个Blob并保存它。 - Cindy Pau

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Cindy Pau · Accepted Answer

您可以像这样将文件放在req的请求正文中，然后将其上传到Azure Blob存储。

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using Microsoft.WindowsAzure.Storage;

namespace FunctionApp5
{
    public static class Function1
    {
        [FunctionName("Function1")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
            ILogger log)
        {
            log.LogInformation("C# HTTP trigger function processed a request.");

            //Here is the keycode.

            //Connect to the Storage Account.
            var storageAccount = CloudStorageAccount.Parse("DefaultEndpointsProtocol=https;AccountName=bowmanimagestorage02;AccountKey=xxxxxxxfile.core.windows.net/");
            var myClient = storageAccount.CreateCloudBlobClient();

            //Here is the container name on portal.
            var container = myClient.GetContainerReference("test");

            //Here is the name you want to save as.
            var blockBlob = container.GetBlockBlobReference("something.txt");

            //Put the stream in this place.
            await blockBlob.UploadFromStreamAsync(req.Body);


            string name = req.Query["name"];

            string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            dynamic data = JsonConvert.DeserializeObject(requestBody);
            name = name ?? data?.name;

            return name != null
                ? (ActionResult)new OkObjectResult($"Hello, {name}")
                : new BadRequestObjectResult("Please pass a name on the query string or in the request body");
        }
    }
}

当然，您也可以传递数据流，密钥代码是相同的。