找不到 Azure Functions 方法错误

Question

我正在尝试设置一个将 blob 导入 azure 媒体服务的 azure 函数。但是当我尝试运行调试模式下的函数时，一些断点永远不会命中，然后我得到这个错误

Microsoft.Azure.WebJobs.Host.FunctionInvocationException : Exception while executing function: Functions.EncodeJob ---> System.MissingMethodException : Method not found: 'System.Threading.Tasks.Task Microsoft.WindowsAzure.MediaServices.Client.CopyBlobHelpers.CopyBlobAsync(Microsoft.WindowsAzure.Storage.Blob.CloudBlockBlob, Microsoft.WindowsAzure.Storage.Blob.CloudBlockBlob, Microsoft.WindowsAzure.Storage.Blob.BlobRequestOptions, System.Threading.CancellationToken)'. at MyApp.WebTasks.EncodeJob.EncodeJobTrigger.CreateAssetFromBlob(CloudBlob sourceBlob,CloudStorageAccount destinationStorageAccount) at C:\Source\Quickflix\MyApp.webtasks\MyApp.WebTasks\EncodeJob\EncodeJobTrigger.cs : 164 at.....(truncated due to length)

看来原因是这里的这个块

            // Call the CopyBlobHelpers.CopyBlobAsync extension method to copy blobs.
        using (var task =
            CopyBlobHelpers.CopyBlobAsync((CloudBlockBlob)sourceBlob,
                (CloudBlockBlob)destinationBlob,
                new BlobRequestOptions(),
                CancellationToken.None))
        {
            task.Wait();
        }

当我注释掉这个块时，我能够命中一个断点，我卡在了它所属的方法中。当它没有被注释掉时，断点永远不会被击中，我得到这个错误。一旦我进入 CreateAssetFromBlob 而不是在实际调用 CopyBlobAsync 的行上，异常似乎就会发生。我已经检查过我所有的 nuget 包都是最新的，并且 bin 目录中 Microsoft.WindowsAzure.MediaServices.Client.Extensions 的版本是相同的版本。该项目构建良好，所以我不确定我缺少什么。我在摸不着头脑为什么它会这样，我是否遗漏了一些明显的东西？

因此使用此示例将项目设置为 Web 应用程序 https://github.com/lindydonna/FunctionsAsWebProject 这似乎工作正常，我可以在本地调试并使用 git 部署到 azure 函数应用程序。

对于更完整的代码片段，这几乎就是我所拥有的

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.WindowsAzure.MediaServices.Client;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Blob;
using Newtonsoft.Json;
using MyApp.Integration.Services;
using MyApp.Logging;

namespace MyApp.WebTasks.EncodeJob
{
    public class EncodeJobTrigger
    {
        private static CloudMediaContext _context;
        private static MediaServicesCredentials _cachedCredentials;

        public static async Task<HttpResponseMessage> Run(HttpRequestMessage req, TraceWriter log)
        {
            var blob = Encode("vidcontainer", "vid.mp4");

            return req.CreateResponse(HttpStatusCode.OK, JsonConvert.SerializeObject(blob.Exists()));
        }

        public static CloudBlob Encode(string containerName, string blobPath)
        {
            var logger = new DebugLogger();
            var amsConnectionString = "connectionstring";
            var blobStorageService = new AzureBlobStorageService(amsConnectionString, logger);
            var destStorageAccount = CloudStorageAccount.Parse("connectionstring");

            string mediaServicesAccountName = "myaccountname";
            string mediaServicesAccountKey = "mykey";

            _cachedCredentials = new MediaServicesCredentials(
                mediaServicesAccountName,
                mediaServicesAccountKey);

            _context = new CloudMediaContext(_cachedCredentials);
            var blob = blobStorageService.FindBlobInContainer(containerName, blobPath);

            ImportBlobIntoAms(blob, destStorageAccount);

            return blob;

        }

        public static IAsset ImportBlobIntoAms(CloudBlob blob, CloudStorageAccount destStorageAccount)
        {

            var asset = CreateAssetFromBlob(blob, destStorageAccount);
            return asset;
        }

        public static IAsset CreateAssetFromBlob(CloudBlob sourceBlob, CloudStorageAccount destinationStorageAccount)
        {

            CloudBlobClient destBlobStorage = destinationStorageAccount.CreateCloudBlobClient();

            // Create a new asset. 
            IAsset asset = _context.Assets.Create("NewAsset_" + Guid.NewGuid(), AssetCreationOptions.None);

            IAccessPolicy writePolicy = _context.AccessPolicies.Create("writePolicy",
                TimeSpan.FromHours(24), AccessPermissions.Write);

            ILocator destinationLocator =
                _context.Locators.CreateLocator(LocatorType.Sas, asset, writePolicy);

            // Get the asset container URI and Blob copy from mediaContainer to assetContainer. 
            CloudBlobContainer destAssetContainer =
                destBlobStorage.GetContainerReference((new Uri(destinationLocator.Path)).Segments[1]);

            if (destAssetContainer.CreateIfNotExists())
            {
                destAssetContainer.SetPermissions(new BlobContainerPermissions
                {
                    PublicAccess = BlobContainerPublicAccessType.Blob
                });
            }

            var assetFile = asset.AssetFiles.Create(sourceBlob.Name);

            ICloudBlob destinationBlob = destAssetContainer.GetBlockBlobReference(assetFile.Name);

            // Call the CopyBlobHelpers.CopyBlobAsync extension method to copy blobs.
            using (var task =
                CopyBlobHelpers.CopyBlobAsync((CloudBlockBlob)sourceBlob,
                    (CloudBlockBlob)destinationBlob,
                    new BlobRequestOptions(),
                    CancellationToken.None))
            {
                task.Wait();
            }

            assetFile.ContentFileSize = (sourceBlob as ICloudBlob).Properties.Length;
            assetFile.Update();
            Console.WriteLine("File {0} is of {1} size", assetFile.Name, assetFile.ContentFileSize);
            //            }

            asset.Update();

            destinationLocator.Delete();
            writePolicy.Delete();

            // Set the primary asset file.
            // If, for example, we copied a set of Smooth Streaming files, 
            // set the .ism file to be the primary file. 
            // If we, for example, copied an .mp4, then the mp4 would be the primary file. 
            var ismAssetFiles = asset.AssetFiles.ToList().FirstOrDefault(f => f.Name.Equals(sourceBlob.Name, StringComparison.OrdinalIgnoreCase));

            // The following code assigns the first .ism file as the primary file in the asset.
            // An asset should have one .ism file.  
            ismAssetFiles.IsPrimary = true;
            ismAssetFiles.Update();

            return asset;
        }
    }
}

更新 1 所以我将此 block/function 更新为异步并且不等待任务，但我仍然遇到相同的错误。更新后的代码如下所示。

            await CopyBlobHelpers.CopyBlobAsync((CloudBlockBlob) sourceBlob,
            (CloudBlockBlob) destinationBlob,
            new BlobRequestOptions(),
            CancellationToken.None);

她也是nugetspackages.config

<?xml version="1.0" encoding="utf-8"?>
<packages>
  <package id="Microsoft.AspNet.WebApi.Client" version="5.2.3" targetFramework="net45" />
  <package id="Microsoft.AspNet.WebApi.Core" version="5.2.3" targetFramework="net45" />
  <package id="Microsoft.Azure.KeyVault.Core" version="2.0.4" targetFramework="net45" />
  <package id="Microsoft.Azure.WebJobs" version="2.0.0" targetFramework="net45" />
  <package id="Microsoft.Azure.WebJobs.Core" version="2.0.0" targetFramework="net45" />
  <package id="Microsoft.CodeDom.Providers.DotNetCompilerPlatform" version="1.0.0" targetFramework="net45" />
  <package id="Microsoft.Data.Edm" version="5.8.2" targetFramework="net45" />
  <package id="Microsoft.Data.OData" version="5.8.2" targetFramework="net45" />
  <package id="Microsoft.Data.Services.Client" version="5.8.2" targetFramework="net45" />
  <package id="Microsoft.Net.Compilers" version="1.0.0" targetFramework="net45" developmentDependency="true" />
  <package id="Newtonsoft.Json" version="9.0.1" targetFramework="net45" />
  <package id="System.ComponentModel.EventBasedAsync" version="4.0.11" targetFramework="net45" />
  <package id="System.Dynamic.Runtime" version="4.0.0" targetFramework="net45" />
  <package id="System.IdentityModel.Tokens.Jwt" version="4.0.2.206221351" targetFramework="net45" />
  <package id="System.Linq.Queryable" version="4.0.0" targetFramework="net45" />
  <package id="System.Net.Requests" version="4.0.11" targetFramework="net45" />
  <package id="System.Spatial" version="5.8.2" targetFramework="net45" />
  <package id="TransientFaultHandling.Core" version="5.1.1209.1" targetFramework="net45" />
  <package id="windowsazure.mediaservices" version="3.8.0.5" targetFramework="net45" />
  <package id="windowsazure.mediaservices.extensions" version="3.8.0.3" targetFramework="net45" />
  <package id="WindowsAzure.Storage" version="8.1.1" targetFramework="net45" />
</packages>

Answer 1

我认为问题出在你的街区

{
    task.Wait();
}

尝试添加这个导入

using Microsoft.Azure.WebJobs;

Answer 2

这可能是由于您使用的 Storage SDK 版本不匹配造成的。能否请您降级到 7.2.1 并重试？

找不到 Azure Functions 方法错误

Azure Functions Method not found error

azure

azure-media-services

azure-blob-storage

azure-functions