Я пытаюсь настроить функцию Azure, которая импортирует большой двоичный объект в службу мультимедиа Azure. Но когда я пытаюсь запустить функцию в режиме отладки, некоторые точки останова никогда не срабатывают, и тогда я получаю эту ошибку.
Microsoft.Azure.WebJobs.Host.FunctionInvocationException : Исключение при выполнении функции: Functions.EncodeJob ---> System.MissingMethodException : Метод не найден: '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.....(усечено из-за длина)
Кажется, причина в этом блоке здесь
// 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 обновлены и что версия Microsoft.WindowsAzure.MediaServices.Client.Extensions в каталоге bin совпадает с версией. Проект строится нормально, поэтому я не уверен, что мне не хватает. Я ломаю голову над тем, почему он так себя ведет, я упускаю что-то очевидное?
Таким образом, проект настроен как веб-приложение с использованием этого примера https://github.com/lindydonna/FunctionsAsWebProject. который, кажется, работает нормально, я могу отлаживать локально и развертывать приложение функций Azure с помощью git.
Для более полного фрагмента кода это почти то, что у меня есть
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 Итак, я обновил этот блок/функцию, чтобы он был асинхронным и не ждал выполнения задачи, но все равно получаю ту же ошибку. Обновленный код выглядит так.
await CopyBlobHelpers.CopyBlobAsync((CloudBlockBlob) sourceBlob,
(CloudBlockBlob) destinationBlob,
new BlobRequestOptions(),
CancellationToken.None);
Также у нее есть пакеты nugets.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>
Microsoft.WindowsAzure.Storage
. Покажите вам файл пакетов. - person Mikhail Shilkov   schedule 09.05.2017