如何从 Azure Functions 中进行 Web 服务调用（对认知服务）？

Question

我一直在尝试从 Azure Functions 中调用认知服务，但运气不佳。我有一个 Blob 触发函数，它在将对象添加到 blob 时启动。我想将一些东西输出到同一个函数中的另一个 blob 容器。

Answer 1

我是通过以下方式实现的

1. 使用以下绑定创建了函数应用程序（Blob 触发）：

   "bindings": [
   {
     "name": "myBlob",
     "type": "blobTrigger",
     "direction": "in",
     "path": "originals/{name}",
     "connection": "AzureWebJobsStorage"
   },
   {
     "type": "blob",
     "name": "outputBlob",
     "path": "extracted/processed-{name}.json",
     "connection": "AzureWebJobsStorage",
     "direction": "out"
   }
   ], "disabled": false
   

2. 使用了以下代码：

   #r "Newtonsoft.Json"
   
   using System;
   using System.Text;
   using System.Net.Http;
   using System.Net.Http.Headers;
   using Newtonsoft.Json;
   
   
   public static async Task Run(Stream myBlob, Stream outputBlob, TraceWriter log)
   {
    string subscriptionKey = "YOUR KEY HERE";
    string uriBase = "https://westcentralus.api.cognitive.microsoft.com/vision/v1.0/recognizeText";
   
    int ID = 0;
    String outputJSON = "json string to be written onto blob";
    HttpClient client = new HttpClient();
    client.DefaultRequestHeaders.Add("Ocp-Apim-Subscription-Key", subscriptionKey);
   
    string requestParameters = "handwriting=true";
    string uri = uriBase + "?" + requestParameters;
    HttpResponseMessage response = null;
    string operationLocation = null;
    HttpContent content = new StreamContent(myBlob);
    content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream");
   
    response = await client.PostAsync(uri, content);
   
    if (response.IsSuccessStatusCode)
       operationLocation = response.Headers.GetValues("Operation-Location").FirstOrDefault();
    else
    {
       log.Info("\nError:\n");
       log.Info((await response.Content.ReadAsStringAsync()));
       return;
     }
   
     string contentString;
     ...
     ...
     System.Threading.Thread.Sleep(1000);
     response = await client.GetAsync(operationLocation);
     contentString = await response.Content.ReadAsStringAsync();
   
     RootObject jObj = JsonConvert.DeserializeObject<RootObject>(contentString);
   
     log.Info(outputJSON); // at this point outputjson has the info needed to write onto the new blob
   
     byte[] data = Encoding.ASCII.GetBytes(outputJSON);
     outputBlob.Write(data,0,data.Length);
   }
   

希望对您有所帮助。干杯! :)