VENTES: 1-800-867-1389

Scénario de basculement de la diffusion de contenu en cas de panne

Mis à jour: août 2014

Cette démonstration explique comment copier le contenu (blobs) d'un élément multimédia dans un autre pour gérer la redondance de la diffusion en continu à la demande. Ce scénario est utile lorsqu'un client souhaite configurer son réseau de diffusion de contenu pour opérer un basculement entre deux centres de données en cas de panne d'un centre de données.

Dans cette démonstration, nous utilisons Microsoft Azure Media Services SDK, les API REST Microsoft Azure Media Services et Azure Storage SDK pour effectuer les tâches suivantes.

  1. Configurer un compte Media Services dans le « Centre de données A ».

  2. Charger un fichier mezzanine dans un élément multimédia source.

  3. Encoder l'élément multimédia dans des fichiers MP4 à vitesse de transmission variable.

  4. Créer un localisateur SAP en lecture seule pour l'élément multimédia source pour obtenir un accès en lecture au conteneur dans le compte Storage associé à l'élément multimédia source.

  5. Obtenir le nom du conteneur de l'élément multimédia source à partir du localisateur SAP en lecture seule créé au cours de l'étape précédente. Ces informations sont nécessaires pour copier des objets blob entre les comptes de stockage (comme expliqué ci-après).

  6. Créer un localisateur d'origine pour l'élément multimédia créé au cours de la tâche d'encodage.



    Ensuite, pour gérer le basculement :



  7. Configurer un compte Media Services dans le « Centre de données B ».

  8. Créer un élément multimédia vide dans le compte Media Services cible.

  9. Créer un localisateur SAP en écriture pour l'élément multimédia vide ciblé pour obtenir un accès en écriture au conteneur dans le compte Storage cible associé à l'élément multimédia cible.

  10. Utiliser le kit de développement logiciel Azure Storage pour copier des objets blob (fichiers d'éléments multimédias) entre le compte de stockage source dans le « Centre de données A » et le compte de stockage cible dans le « Centre de données B » (ces comptes de stockage sont associés aux éléments multimédias qui présentent un intérêt).

  11. Associer les objets blob (fichiers d'éléments multimédias) copiés dans le conteneur d'objets blob cible à l'élément multimédia cible.

  12. Créer un localisateur d'origine pour l'élément multimédia dans le « Centre de données B » et indiquer l'Id du localisateur créé pour l'élément multimédia dans le « Centre de données A ».

    Vous obtenez les URL de diffusion en continu lorsque les chemins d'accès aux URL sont identiques (seules les URL de base sont différentes).

  13. Pour gérer les éventuelles pannes, vous pouvez ensuite créer un réseau de diffusion de contenu par-dessus ces localisateurs d'origine.

Vous devez tenir compte des éléments suivants :

  • La version actuelle de Media Services SDK ne permet pas de créer un localisateur avec l'ID spécifié. Pour effectuer cette tâche, nous utilisons l'API REST de Media Services.

  • La version actuelle de Media Services SDK ne permet pas de créer des informations IAssetFile par programme pour associer un élément multimédia à des fichiers d'éléments multimédias. Pour effectuer cette tâche, nous employons l'API REST de Media Services CreateFileInfos.

  • Les éléments multimédias à chiffrement de stockage (AssetCreationOptions.StorageEncrypted) ne peuvent pas être répliqués (la clé de chiffrement est différente dans les deux comptes Media Services).

  • Pour profiter de la mise en package dynamique, vous devez tout d'abord obtenir au moins une unité réservée pour la diffusion en continu à la demande. Pour plus d’informations, voir Empaquetage dynamique.

TipConseil
Vous pouvez également utiliser l'Media Services outil Réplicateur pour implémenter manuellement un scénario de diffusion en continu sur basculement. Cet outil permet de répliquer les éléments multimédias entre les deux comptes Media Services.

  • Deux comptes Media Services dans un abonnement Azure nouveau ou existant. Voir la rubrique Procédure de création d'un compte Service de média.

  • systèmes d'exploitation : Windows 7, Windows 2008 R2 ou Windows 8.

  • .NET Framework 4.5 ou .NET Framework 4.

  • Visual Studio 2012 ou Visual Studio 2010 SP1 (Professionnel, Premium, Express ou Édition Intégrale).

Dans cette section, vous allez créer et configurer un projet d'application de console en C#.

  1. Utilisez Visual Studio 2012 ou Visual Studio 2010 SP1 pour créer une solution contenant le projet application de console C#. Saisissez HandleRedundancyForOnDemandStreaming pour le nom et cliquez sur OK.

  2. Créez le dossier SupportFiles au même niveau que le fichier de projet HandleRedundancyForOnDemandStreaming.csproj. Dans le dossier SupportFiles, créez les sous-dossiers OutputFiles et MP4Files. Copiez un fichier .mp4 dans le dossier MP4Files (cet exemple utilise le fichier BigBuckBunny.mp4).

  3. Utilisez Nuget pour ajouter des références aux DLL liées à Media Services. Dans le menu principal Visual Studio, sélectionnez OUTILS -> Gestionnaire de package de bibliothèque -> Console du gestionnaire de package. Dans la fenêtre de console, tapez Install-Package windowsazure.mediaservices, puis appuyez sur Entrée.

  4. Ajoutez les autres références nécessaires pour ce projet : System.Configuration, System.Runtime.Serialization et System.Web.

  5. Remplacez les instructions insérées par défaut dans le fichier Programs.cs par les suivantes :

    using System;
    using System.Configuration;
    using System.Globalization;
    using System.IO;
    using System.Net;
    using System.Runtime.Serialization.Json;
    using System.Text;
    using System.Threading;
    using System.Threading.Tasks;
    using System.Web;
    using System.Xml;
    using System.Linq;
    using Microsoft.WindowsAzure;
    using Microsoft.WindowsAzure.MediaServices.Client;
    using Microsoft.WindowsAzure.Storage;
    using Microsoft.WindowsAzure.Storage.Blob;
    using Microsoft.WindowsAzure.Storage.Auth;
    
    
  6. Rajoutez la section appSettings dans le fichier .config et actualisez les valeurs en tenant compte du nom et de la clé de Media Services et du stockage.

    <appSettings>
      <add key="MediaServicesAccountNameSource" value="Media-Services-Account-Name-Source"/>
      <add key="MediaServicesAccountKeySource" value="Media-Services-Account-Key-Source"/>
      <add key="MediaServicesStorageAccountNameSource" value="Media-Services-Storage-Account-Name-Source"/>
      <add key="MediaServicesStorageAccountKeySource" value="Media-Services-Storage-Account-Key-Source"/>
      <add key="MediaServicesAccountNameTarget" value="Media-Services-Account-Name-Target" />
      <add key="MediaServicesAccountKeyTarget" value=" Media-Services-Account-Key-Target" />
      <add key="MediaServicesStorageAccountNameTarget" value=" Media-Services-Storage-Account-Name-Target" />
      <add key="MediaServicesStorageAccountKeyTarget" value=" Media-Services-Storage-Account-Key-Target" />
    </appSettings>
    
    

  1. Ajoutez les champs de classe suivants dans la classe Program.

    // Read values from the App.config file.
    private static readonly string MediaServicesAccountNameSource = ConfigurationManager.AppSettings["MediaServicesAccountNameSource"];
    private static readonly string MediaServicesAccountKeySource = ConfigurationManager.AppSettings["MediaServicesAccountKeySource"];
    private static readonly string StorageNameSource = ConfigurationManager.AppSettings["MediaServicesStorageAccountNameSource"];
    private static readonly string StorageKeySource = ConfigurationManager.AppSettings["MediaServicesStorageAccountKeySource"];
    
    private static readonly string MediaServicesAccountNameTarget = ConfigurationManager.AppSettings["MediaServicesAccountNameTarget"];
    private static readonly string MediaServicesAccountKeyTarget = ConfigurationManager.AppSettings["MediaServicesAccountKeyTarget"];
    private static readonly string StorageNameTarget = ConfigurationManager.AppSettings["MediaServicesStorageAccountNameTarget"];
    private static readonly string StorageKeyTarget = ConfigurationManager.AppSettings["MediaServicesStorageAccountKeyTarget"];
    
    // Base support files path.  Update this field to point to the base path  
    // for the local support files folder that you create. 
    private static readonly string SupportFiles = Path.GetFullPath(@"../..\SupportFiles");
    
    // Paths to support files (within the above base path). 
    private static readonly string SingleInputMp4Path = Path.GetFullPath(SupportFiles + @"\MP4Files\BigBuckBunny.mp4");
    private static readonly string OutputFilesFolder = Path.GetFullPath(SupportFiles + @"\OutputFiles");
    
    // Class-level field used to keep a reference to the service context.
    static private CloudMediaContext _contextSource = null;
    static private CloudMediaContext _contextTarget = null;
    static private MediaServicesCredentials _cachedCredentialsSource = null;
    static private MediaServicesCredentials _cachedCredentialsTarget = null;
    
  2. Remplacez la définition de la méthode par défaut Main par celle-ci :

    static void Main(string[] args)
    {
        _cachedCredentialsSource = new MediaServicesCredentials(
                        MediaServicesAccountNameSource,
                        MediaServicesAccountKeySource);
    
        _cachedCredentialsTarget = new MediaServicesCredentials(
                        MediaServicesAccountNameTarget,
                        MediaServicesAccountKeyTarget);
    
        // Get server context.    
        _contextSource = new CloudMediaContext(_cachedCredentialsSource);
        _contextTarget = new CloudMediaContext(_cachedCredentialsTarget);
    
    
        IAsset assetSingleFile = CreateAssetAndUploadSingleFile(_contextSource,
                                    AssetCreationOptions.None,
                                    SingleInputMp4Path);
    
        IJob job = CreateEncodingJob(_contextSource, assetSingleFile);
    
        if (job.State != JobState.Error)
        {
            IAsset sourceOutputAsset = job.OutputMediaAssets[0];
            // Get the locator for Smooth Streaming
            var sourceOriginLocator = GetStreamingOriginLocator(_contextSource, sourceOutputAsset);
    
            Console.WriteLine("Locator Id: {0}", sourceOriginLocator.Id);
    
    
            // 1.Create a read-only SAS locator for the source asset to have read access to the container in the source Storage account (associated with the source Media Services account)
            var readSasLocator = GetSasReadLocator(_contextSource, sourceOutputAsset);
    
    
            // 2.Get the container name of the source asset from the read-only SAS locator created in the previous step
            string containerName = (new Uri(readSasLocator.Path)).Segments[1];
    
    
            // 3.Create a target empty asset in the target Media Services account
            var targetAsset = CreateTargetEmptyAsset(_contextTarget, containerName);
    
            // 4.Create a write SAS locator for the target empty asset to have write access to the container in the target Storage account (associated with the target Media Services account)
            ILocator writeSasLocator = CreateSasWriteLocator(_contextTarget, targetAsset);
    
            // Get asset container name.
            string targetContainerName = (new Uri(writeSasLocator.Path)).Segments[1];
    
    
            // 5.Copy the blobs in the source container (source asset) to the target container (target empty asset)
            CopyBlobsFromDifferentStorage(containerName, targetContainerName, StorageNameSource, StorageKeySource, StorageNameTarget, StorageKeyTarget);
    
    
            // 6.Use the CreateFileInfos Media Services REST API to automatically generate all the IAssetFile’s for the target asset. 
            //      This API call is not supported in the current Media Services SDK for .NET. 
            CreateFileInfosForAssetWithRest(_contextTarget, targetAsset, MediaServicesAccountNameTarget, MediaServicesAccountKeyTarget);
    
            // Check if the AssetFiles are now  associated with the asset.
            Console.WriteLine("Asset files assocated with the {0} asset:", targetAsset.Name);
            foreach (var af in targetAsset.AssetFiles)
            {
                Console.WriteLine(af.Name);
            }
    
            // 7.Copy the Origin locator of the source asset to the target asset by using the same Id
            var replicatedLocatorPath = CreateOriginLocatorWithRest(_contextTarget,
                        MediaServicesAccountNameTarget, MediaServicesAccountKeyTarget,
                        sourceOriginLocator.Id, targetAsset.Id);
    
            // Create a full URL to the manifest file. Use this for playback
            // in streaming media clients. 
            string originalUrlForClientStreaming = sourceOriginLocator.Path + GetPrimaryFile(sourceOutputAsset).Name + "/manifest";
    
            Console.WriteLine("Original Locator Path: {0}\n", originalUrlForClientStreaming);
    
            string replicatedUrlForClientStreaming = replicatedLocatorPath + GetPrimaryFile(sourceOutputAsset).Name + "/manifest";
    
            Console.WriteLine("Replicated Locator Path: {0}", replicatedUrlForClientStreaming);
    
            readSasLocator.Delete();
            writeSasLocator.Delete();
    }
    
  3. Les définitions de méthode dérivées de Main sont indiquées ci-après.

    public static IAsset CreateAssetAndUploadSingleFile(CloudMediaContext context,
                                                    AssetCreationOptions assetCreationOptions,
                                                    string singleFilePath)
    {
        // For the AssetCreationOptions you can specify 
        // encryption options.
        //      None:  no encryption. By default, storage encryption is used. If you want to 
        //        create an unencrypted asset, you must set this option.
        //      StorageEncrypted:  storage encryption. Encrypts a clear input file 
        //        before it is uploaded to Azure storage. This is the default if not specified
        //      CommonEncryptionProtected:  for Common Encryption Protected (CENC) files. An 
        //        example is a set of files that are already PlayReady encrypted. 
    
        var assetName = "UploadSingleFile_" + DateTime.UtcNow.ToString();
    
        var asset = context.Assets.Create(assetName, assetCreationOptions);
    
        Console.WriteLine("Asset name: " + asset.Name);
    
        var fileName = Path.GetFileName(singleFilePath);
    
        var assetFile = asset.AssetFiles.Create(fileName);
    
        Console.WriteLine("Created assetFile {0}", assetFile.Name);
    
        Console.WriteLine("Upload {0}", assetFile.Name);
    
        assetFile.Upload(singleFilePath);
        Console.WriteLine("Done uploading of {0}", assetFile.Name);
    
        return asset;
    }
    
    public static IJob CreateEncodingJob(CloudMediaContext context, IAsset asset)
    {
        // Declare a new job.
        IJob job = context.Jobs.Create("My encoding job");
    
        // Get a media processor reference, and pass to it the name of the 
        // processor to use for the specific task.
        IMediaProcessor processor = GetLatestMediaProcessorByName(context,
                                                "Windows Azure Media Encoder");
    
        // Create a task with the encoding details, using a string preset.
        // In this case "H264 Adaptive Bitrate MP4 Set 720p" preset is used.
        ITask task = job.Tasks.AddNew("My encoding task",
            processor,
            "H264 Adaptive Bitrate MP4 Set 720p",
            TaskOptions.ProtectedConfiguration);
    
        // Specify the input asset to be encoded.
        task.InputAssets.Add(asset);
    
        // Add an output asset to contain the results of the job. 
        // This output is specified as AssetCreationOptions.None, which 
        // means the output asset is in the clear (unencrypted). 
        var outputAssetName = "OutputAsset_" + Guid.NewGuid();
        task.OutputAssets.AddNew(outputAssetName,
            AssetCreationOptions.None);
    
        // Use the following event handler to check job progress.  
        job.StateChanged += new
                EventHandler<JobStateChangedEventArgs>(StateChanged);
    
        // Launch the job.
        job.Submit();
    
        // Optionally log job details. This displays basic job details
        // to the console and saves them to a JobDetails-{JobId}.txt file 
        // in your output folder.
        LogJobDetails(context, job.Id);
    
        // Check job execution and wait for job to finish. 
        Task progressJobTask = job.GetExecutionProgressTask(CancellationToken.None);
        progressJobTask.Wait();
    
        // Get an updated job reference.
        job = GetJob(context, job.Id);
    
        // Since we the output asset contains a set of Smooth Streaming files,
        // set the .ism file to be the primary file
        if (job.State != JobState.Error)
            SetPrimaryFile(job.OutputMediaAssets[0]);
    
        return job;
    }
    
    // Create a locator URL to a streaming media asset 
    // on an origin server.
    public static ILocator GetStreamingOriginLocator(CloudMediaContext context, IAsset assetToStream)
    {
        // Get a reference to the streaming manifest file from the  
        // collection of files in the asset. 
        IAssetFile manifestFile = GetPrimaryFile(assetToStream);
    
        // Create a 30-day readonly access policy. 
        IAccessPolicy policy = context.AccessPolicies.Create("Streaming policy",
            TimeSpan.FromDays(30),
            AccessPermissions.Read);
    
        // Create a locator to the streaming content on an origin. 
        ILocator originLocator = context.Locators.CreateLocator(LocatorType.OnDemandOrigin,
            assetToStream,
            policy,
            DateTime.UtcNow.AddMinutes(-5));
    
        // Return the locator. 
        return originLocator;
    }
    
    public static ILocator GetSasReadLocator(CloudMediaContext context, IAsset asset)
    {
        IAccessPolicy accessPolicy = context.AccessPolicies.Create("File Download Policy",
            TimeSpan.FromDays(30), AccessPermissions.Read);
    
        ILocator sasLocator = context.Locators.CreateLocator(LocatorType.Sas,
            asset, accessPolicy);
    
        return sasLocator;
    }
    
    public static ILocator CreateSasWriteLocator(CloudMediaContext context, IAsset asset)
    {
    
        IAccessPolicy writePolicy = context.AccessPolicies.Create("Write Policy",
            TimeSpan.FromDays(30), AccessPermissions.Write);
    
        ILocator sasLocator = context.Locators.CreateLocator(LocatorType.Sas,
            asset, writePolicy);
    
        return sasLocator;
    }
    
    public static IAsset CreateTargetEmptyAsset(CloudMediaContext context, string containerName)
    {
        // Create a new asset.
        IAsset assetToBeProcessed = context.Assets.Create(containerName,
            AssetCreationOptions.None);
    
        return assetToBeProcessed;
    }
    
    public static void CreateFileInfosForAssetWithRest(CloudMediaContext context, IAsset asset, string mediaServicesAccountNameTarget,
        string mediaServicesAccountKeyTarget)
    {
        string apiServer = "";
        string scope = "";
        string acsBaseAddress = "";
    
        string acsToken = GetAcsBearerToken(mediaServicesAccountNameTarget,
                                mediaServicesAccountKeyTarget, scope, acsBaseAddress);
    
        if (!string.IsNullOrEmpty(acsToken))
        {
            CreateFileInfos(apiServer, acsToken, asset.Id);
        }
    }
    
    public static string CreateOriginLocatorWithRest(CloudMediaContext context, string mediaServicesAccountNameTarget,
        string mediaServicesAccountKeyTarget, string locatorIdToReplicate, string targetAssetId)
    {
        //Make sure we are not asking for a duplicate:
        var locator = context.Locators.Where(l => l.Id == locatorIdToReplicate).FirstOrDefault();
        if (locator != null)
            return "";
    
        string locatorNewPath = "";
        string apiServer = "";
        string scope = "";
        string acsBaseAddress = "";
    
        string acsToken = GetAcsBearerToken(mediaServicesAccountNameTarget,
                                mediaServicesAccountKeyTarget, scope, acsBaseAddress);
    
        if (!string.IsNullOrEmpty(acsToken))
        {
            var asset = context.Assets.Where(a => a.Id == targetAssetId).FirstOrDefault();
    
            var accessPolicy = context.AccessPolicies.Create("RestTest", TimeSpan.FromDays(100),
                                                                AccessPermissions.Read);
            if (asset != null)
            {
                string redirectedServiceUri = null;
    
                var xmlResponse = CreateLocator(apiServer, out redirectedServiceUri, acsToken,
                                                            asset.Id, accessPolicy.Id,
                                                            (int)LocatorType.OnDemandOrigin,
                                                            DateTime.UtcNow.AddMinutes(-10), locatorIdToReplicate);
    
                Console.WriteLine("Redirected to: " + redirectedServiceUri);
                if (xmlResponse != null)
                {
                    Console.WriteLine(String.Format("Locator Id: {0}",
                                                    xmlResponse.GetElementsByTagName("Id")[0].InnerText));
                    Console.WriteLine(String.Format("Locator Path: {0}",
                            xmlResponse.GetElementsByTagName("Path")[0].InnerText));
    
    
                    locatorNewPath = xmlResponse.GetElementsByTagName("Path")[0].InnerText;
                }
            }
        }
    
        return locatorNewPath;
    }
    
    
    public static void SetPrimaryFile(IAsset asset)
    {
    
        var ismAssetFiles = asset.AssetFiles.ToList().
                    Where(f => f.Name.EndsWith(".ism", StringComparison.OrdinalIgnoreCase))
                    .ToArray();
    
        if (ismAssetFiles.Count() != 1)
            throw new ArgumentException("The asset should have only one, .ism file");
    
        ismAssetFiles.First().IsPrimary = true;
        ismAssetFiles.First().Update();
    }
    
    public static IAssetFile GetPrimaryFile(IAsset asset)
    {
        var theManifest =
                from f in asset.AssetFiles
                where f.Name.EndsWith(".ism")
                select f;
    
        // Cast the reference to a true IAssetFile type. 
        IAssetFile manifestFile = theManifest.First();
    
        return manifestFile;
    }
    
    public static IAsset RefreshAsset(CloudMediaContext context, IAsset asset)
    {
        asset = context.Assets.Where(a => a.Id == asset.Id).FirstOrDefault();
        return asset;
    }
    
    
    public static void CopyBlobsFromDifferentStorage(string sourceContainerName, string targetContainerName,
                                        string srcAccountName, string srcAccountKey,
                                        string destAccountName, string destAccountKey)
    {
        var srcAccount = new CloudStorageAccount(new StorageCredentials(srcAccountName, srcAccountKey), true);
        var destAccount = new CloudStorageAccount(new StorageCredentials(destAccountName, destAccountKey), true);
    
        var cloudBlobClient = srcAccount.CreateCloudBlobClient();
        var targetBlobClient = destAccount.CreateCloudBlobClient();
    
        var sourceContainer = cloudBlobClient.GetContainerReference(sourceContainerName);
        var targetContainer = targetBlobClient.GetContainerReference(targetContainerName);
        targetContainer.CreateIfNotExists();
    
    
        string blobToken = sourceContainer.GetSharedAccessSignature(new SharedAccessBlobPolicy()
        {
            // Specify the expiration time for the signature.
            SharedAccessExpiryTime = DateTime.Now.AddDays(1),
            // Specify the permissions granted by the signature.
            Permissions = SharedAccessBlobPermissions.Write | SharedAccessBlobPermissions.Read
        });
    
    
        foreach (var sourceBlob in sourceContainer.ListBlobs())
        {
            string fileName = (sourceBlob as ICloudBlob).Name;
            var sourceCloudBlob = sourceContainer.GetBlockBlobReference(fileName);
            sourceCloudBlob.FetchAttributes();
    
            if (sourceCloudBlob.Properties.Length > 0)
            {
                var destinationBlob = targetContainer.GetBlockBlobReference(fileName);
                destinationBlob.StartCopyFromBlob(new Uri(sourceBlob.Uri.AbsoluteUri + blobToken));
    
                while (true)
                {
                    // The StartCopyFromBlob is an async operation, 
                    // so we want to check if the copy operation is completed before proceeding. 
                    // To do that, we call FetchAttributes on the blob and check the CopyStatus. 
                    destinationBlob.FetchAttributes();
                    if (destinationBlob.CopyState.Status != CopyStatus.Pending)
                    {
                        break;
                    }
                    //It's still not completed. So wait for some time.
                    System.Threading.Thread.Sleep(1000);
                }
            }
    
            Console.WriteLine(fileName);
        }
    
        Console.WriteLine("Done copying.");
    }
    private static IMediaProcessor GetLatestMediaProcessorByName(CloudMediaContext context, string mediaProcessorName)
    {
        // The possible strings that can be passed into the 
        // method for the mediaProcessor parameter:
        // Windows Azure Media Encoder
        // Windows Azure Media Packager
        // Windows Azure Media Encryptor
        //   Storage Decryption
    
        var processor = context.MediaProcessors.Where(p => p.Name == mediaProcessorName).
            ToList().OrderBy(p => new Version(p.Version)).LastOrDefault();
    
        if (processor == null)
            throw new ArgumentException(string.Format("Unknown media processor", mediaProcessorName));
    
        return processor;
    }
    
    // This method is a handler for events that track job progress.   
    private static void StateChanged(object sender, JobStateChangedEventArgs e)
    {
        Console.WriteLine("Job state changed event:");
        Console.WriteLine("  Previous state: " + e.PreviousState);
        Console.WriteLine("  Current state: " + e.CurrentState);
    
        switch (e.CurrentState)
        {
            case JobState.Finished:
                Console.WriteLine();
                Console.WriteLine("********************");
                Console.WriteLine("Job is finished.");
                Console.WriteLine("Please wait while local tasks or downloads complete...");
                Console.WriteLine("********************");
                Console.WriteLine();
                Console.WriteLine();
                break;
            case JobState.Canceling:
            case JobState.Queued:
            case JobState.Scheduled:
            case JobState.Processing:
                Console.WriteLine("Please wait...\n");
                break;
            case JobState.Canceled:
            case JobState.Error:
                // Cast sender as a job.
                IJob job = (IJob)sender;
                // Display or log error details as needed.
                LogJobStop(null, job.Id);
                break;
            default:
                break;
        }
    }
    
    private static void LogJobStop(CloudMediaContext context, string jobId)
    {
        StringBuilder builder = new StringBuilder();
        IJob job = GetJob(context, jobId);
    
        builder.AppendLine("\nThe job stopped due to cancellation or an error.");
        builder.AppendLine("***************************");
        builder.AppendLine("Job ID: " + job.Id);
        builder.AppendLine("Job Name: " + job.Name);
        builder.AppendLine("Job State: " + job.State.ToString());
        builder.AppendLine("Job started (server UTC time): " + job.StartTime.ToString());
        // Log job errors if they exist.  
        if (job.State == JobState.Error)
        {
            builder.Append("Error Details: \n");
            foreach (ITask task in job.Tasks)
            {
                foreach (ErrorDetail detail in task.ErrorDetails)
                {
                    builder.AppendLine("  Task Id: " + task.Id);
                    builder.AppendLine("    Error Code: " + detail.Code);
                    builder.AppendLine("    Error Message: " + detail.Message + "\n");
                }
            }
        }
        builder.AppendLine("***************************\n");
        // Write the output to a local file and to the console. The template 
        // for an error output file is:  JobStop-{JobId}.txt
        string outputFile = OutputFilesFolder + @"\JobStop-" + JobIdAsFileName(job.Id) + ".txt";
        WriteToFile(outputFile, builder.ToString());
        Console.Write(builder.ToString());
    }
    
    private static void LogJobDetails(CloudMediaContext context, string jobId)
    {
        StringBuilder builder = new StringBuilder();
        IJob job = GetJob(context, jobId);
    
        builder.AppendLine("\nJob ID: " + job.Id);
        builder.AppendLine("Job Name: " + job.Name);
        builder.AppendLine("Job submitted (client UTC time): " + DateTime.UtcNow.ToString());
    
        // Write the output to a local file and to the console. The template 
        // for an error output file is:  JobDetails-{JobId}.txt
        string outputFile = OutputFilesFolder + @"\JobDetails-" + JobIdAsFileName(job.Id) + ".txt";
        WriteToFile(outputFile, builder.ToString());
        Console.Write(builder.ToString());
    }
    
    // Replace ":" with "_" in Job id values so they can 
    // be used as log file names.  
    private static string JobIdAsFileName(string jobID)
    {
        return jobID.Replace(":", "_");
    }
    
    // Write method output to the output files folder.
    private static void WriteToFile(string outFilePath, string fileContent)
    {
        StreamWriter sr = File.CreateText(outFilePath);
        sr.WriteLine(fileContent);
        sr.Close();
    }
    
    private static IJob GetJob(CloudMediaContext context, string jobId)
    {
        // Use a Linq select query to get an updated 
        // reference by Id. 
        var jobInstance =
            from j in context.Jobs
            where j.Id == jobId
            select j;
    
        // Return the job reference as an Ijob. 
        IJob job = jobInstance.FirstOrDefault();
    
        return job;
    }
    
    private static IAsset GetAsset(CloudMediaContext context, string assetId)
    {
        // Use a LINQ Select query to get an asset.
        var assetInstance =
            from a in context.Assets
            where a.Id == assetId
            select a;
    
        // Reference the asset as an IAsset.
        IAsset asset = assetInstance.FirstOrDefault();
    
        return asset;
    }
    
    public static void DeleteAllAssets(CloudMediaContext context)
    {
        // Loop through and delete all assets.
        foreach (IAsset asset in context.Assets)
        {
            DeleteLocatorsForAsset(context, asset);
    
            asset.Delete();
        }
    }
    
    public static void DeleteLocatorsForAsset(CloudMediaContext context, IAsset asset)
    {
        string assetId = asset.Id;
        var locators = from a in context.Locators
                        where a.AssetId == assetId
                        select a;
        foreach (var locator in locators)
        {
            Console.WriteLine("Deleting locator {0} for asset {1}", locator.Path, assetId);
    
            locator.Delete();
        }
    }
    
    public static void DeleteAccessPolicy(CloudMediaContext context, string existingPolicyId)
    {
        // To delete a specific access policy, get a reference to the policy.  
        // based on the policy Id passed to the method.
        var policyInstance =
                from p in context.AccessPolicies
                where p.Id == existingPolicyId
                select p;
    
        IAccessPolicy policy = policyInstance.FirstOrDefault();
    
        policy.Delete();
    
    }
    
    //////////////////////////////////////////////////////
    /// The following methods use REST calls.
    //////////////////////////////////////////////////////
    
    public static string GetAcsBearerToken(string clientId, string clientSecret, string scope, string accessControlServiceUri)
    {
        if (string.IsNullOrEmpty(clientId))
            throw new ArgumentNullException("clientId");
    
        if (string.IsNullOrEmpty(clientSecret))
            throw new ArgumentNullException("clientSecret");
    
        if (string.IsNullOrEmpty(scope))
        {
            scope = "urn:WindowsAzureMediaServices";
        }
        else if (!scope.ToLower().StartsWith("urn:"))
        {
            scope = "urn:" + scope;
        }
    
        if (string.IsNullOrEmpty(accessControlServiceUri))
        {
            accessControlServiceUri = "https://wamsprodglobal001acs.accesscontrol.windows.net/v2/OAuth2-13";
        }
        else if (!accessControlServiceUri.ToLower().EndsWith("/v2/oauth2-13"))
        {
            accessControlServiceUri = accessControlServiceUri.TrimEnd('/') + "/v2/OAuth2-13";
        }
    
        HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(accessControlServiceUri);
        request.Method = "POST";
        request.ContentType = "application/x-www-form-urlencoded";
        request.KeepAlive = true;
        string acsBearerToken = null;
    
        var requestBytes = Encoding.ASCII.GetBytes("grant_type=client_credentials&client_id=" +
            clientId + "&client_secret=" + HttpUtility.UrlEncode(clientSecret) +
            "&scope=" + HttpUtility.UrlEncode(scope));
        request.ContentLength = requestBytes.Length;
    
        var requestStream = request.GetRequestStream();
        requestStream.Write(requestBytes, 0, requestBytes.Length);
        requestStream.Close();
    
        var response = (HttpWebResponse)request.GetResponse();
    
        if (response.StatusCode == HttpStatusCode.OK)
        {
            using (Stream responseStream = response.GetResponseStream())
            {
                using (StreamReader stream = new StreamReader(responseStream))
                {
                    string responseString = stream.ReadToEnd();
                    var reader = JsonReaderWriterFactory.CreateJsonReader(Encoding.UTF8.GetBytes(responseString),
                        new XmlDictionaryReaderQuotas());
    
                    while (reader.Read())
                    {
                        if ((reader.Name == "access_token") && (reader.NodeType == XmlNodeType.Element))
                        {
                            if (reader.Read())
                            {
                                acsBearerToken = reader.Value;
                                break;
                            }
                        }
                    }
                }
            }
        }
    
        return acsBearerToken;
    }
    
    public static XmlDocument CreateLocator(string mediaServicesApiServerUri,
                                            out string redirectedMediaServicesApiServerUri,
                                            string acsBearerToken, string assetId,
                                            string accessPolicyId, int locatorType,
                                            DateTime startTime, string locatorIdToReplicate = null,
                                            bool autoRedirect = true)
    {
        if (string.IsNullOrEmpty(mediaServicesApiServerUri))
        {
            mediaServicesApiServerUri = "https://media.windows.net/api/";
        }
        if (!mediaServicesApiServerUri.EndsWith("/"))
            mediaServicesApiServerUri = mediaServicesApiServerUri + "/";
    
        if (string.IsNullOrEmpty(acsBearerToken)) throw new ArgumentNullException("acsBearerToken");
        if (string.IsNullOrEmpty(assetId)) throw new ArgumentNullException("assetId");
        if (string.IsNullOrEmpty(accessPolicyId)) throw new ArgumentNullException("accessPolicyId");
    
        redirectedMediaServicesApiServerUri = null;
        XmlDocument xmlResponse = null;
    
        StringBuilder sb = new StringBuilder();
        sb.Append("{ \"AssetId\" : \"" + assetId + "\"");
        sb.Append(", \"AccessPolicyId\" : \"" + accessPolicyId + "\"");
        sb.Append(", \"Type\" : \"" + locatorType + "\"");
        if (startTime != DateTime.MinValue)
            sb.Append(", \"StartTime\" : \"" + startTime.ToString("G", CultureInfo.CreateSpecificCulture("en-us")) + "\"");
        if (!string.IsNullOrEmpty(locatorIdToReplicate))
            sb.Append(", \"Id\" : \"" + locatorIdToReplicate + "\"");
        sb.Append("}");
    
        string requestbody = sb.ToString();
    
        try
        {
            var request = GenerateRequest("POST", mediaServicesApiServerUri, "Locators",
                null, acsBearerToken, requestbody);
            var response = (HttpWebResponse)request.GetResponse();
    
            switch (response.StatusCode)
            {
                case HttpStatusCode.MovedPermanently:
                    //Recurse once with the mediaServicesApiServerUri redirect Location:
                    if (autoRedirect)
                    {
                        redirectedMediaServicesApiServerUri = response.Headers["Location"];
                        string secondRedirection = null;
                        xmlResponse = CreateLocator(redirectedMediaServicesApiServerUri,
                                                    out secondRedirection, acsBearerToken,
                                                    assetId, accessPolicyId, locatorType,
                                                    startTime, locatorIdToReplicate, false);
                    }
                    else
                    {
                        Console.WriteLine("Redirection to {0} failed.",
                            mediaServicesApiServerUri);
                        return null;
                    }
                    break;
                case HttpStatusCode.Created:
                    using (Stream responseStream = response.GetResponseStream())
                    {
                        using (StreamReader stream = new StreamReader(responseStream))
                        {
                            string responseString = stream.ReadToEnd();
                            var reader = JsonReaderWriterFactory.
                                CreateJsonReader(Encoding.UTF8.GetBytes(responseString),
                                    new XmlDictionaryReaderQuotas());
    
                            xmlResponse = new XmlDocument();
                            reader.Read();
                            xmlResponse.LoadXml(reader.ReadInnerXml());
                        }
                    }
                    break;
    
                default:
                    Console.WriteLine(response.StatusDescription);
                    break;
            }
        }
        catch (WebException ex)
        {
            Console.WriteLine(ex.Message);
        }
    
        return xmlResponse;
    }
    
    public static void CreateFileInfos(string mediaServicesApiServerUri,
                                string acsBearerToken,
                                string assetId
                                )
    {
        if (String.IsNullOrEmpty(mediaServicesApiServerUri))
        {
            mediaServicesApiServerUri = "https://media.windows.net/api/";
        }
        if (!mediaServicesApiServerUri.EndsWith("/"))
            mediaServicesApiServerUri = mediaServicesApiServerUri + "/";
    
        if (String.IsNullOrEmpty(acsBearerToken)) throw new ArgumentNullException("acsBearerToken");
        if (String.IsNullOrEmpty(assetId)) throw new ArgumentNullException("assetId");
    
    
        string id = assetId.Replace(":", "%");
    
        UriBuilder builder = new UriBuilder(mediaServicesApiServerUri);
        builder.Path = Path.Combine(builder.Path, "CreateFileInfos");
        builder.Query = String.Format(CultureInfo.InvariantCulture, "assetid='{0}'", assetId);
    
        try
        {
            var request = GenerateRequest("GET", mediaServicesApiServerUri, "CreateFileInfos",
                String.Format(CultureInfo.InvariantCulture, "assetid='{0}'", assetId), acsBearerToken, null);
    
            using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
            {
                if (response.StatusCode == HttpStatusCode.MovedPermanently)
                {
                    string redirectedMediaServicesApiUrl = response.Headers["Location"];
    
                    CreateFileInfos(redirectedMediaServicesApiUrl, acsBearerToken, assetId);
                }
                else if ((response.StatusCode != HttpStatusCode.OK) &&
                    (response.StatusCode != HttpStatusCode.Accepted) &&
                    (response.StatusCode != HttpStatusCode.Created) &&
                    (response.StatusCode != HttpStatusCode.NoContent))
                {
                    // TODO: Throw a more specific exception.
                    throw new Exception("Invalid response received ");
                }
            }
        }
        catch (WebException ex)
        {
            Console.WriteLine(ex.Message);
        }
    }
    
    
    private static HttpWebRequest GenerateRequest(string verb,
                                                    string mediaServicesApiServerUri,
                                                    string resourcePath, string query,
                                                    string acsBearerToken, string requestbody)
    {
        var uriBuilder = new UriBuilder(mediaServicesApiServerUri);
        uriBuilder.Path += resourcePath;
        if (query != null)
        {
            uriBuilder.Query = query;
        }
        HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(uriBuilder.Uri);
        request.AllowAutoRedirect = false; //We manage our own redirects.
        request.Method = verb;
    
        if (resourcePath == "$metadata")
            request.MediaType = "application/xml";
        else
        {
            request.ContentType = "application/json;odata=verbose";
            request.Accept = "application/json;odata=verbose";
        }
    
        request.Headers.Add("DataServiceVersion", "3.0");
        request.Headers.Add("MaxDataServiceVersion", "3.0");
        request.Headers.Add("x-ms-version", "2.1");
        request.Headers.Add(HttpRequestHeader.Authorization, "Bearer " + acsBearerToken);
    
        if (requestbody != null)
        {
            var requestBytes = Encoding.ASCII.GetBytes(requestbody);
            request.ContentLength = requestBytes.Length;
    
            var requestStream = request.GetRequestStream();
            requestStream.Write(requestBytes, 0, requestBytes.Length);
            requestStream.Close();
        }
        else
        {
            request.ContentLength = 0;
        }
        return request;
    }
    
    
    

Vous pouvez maintenant utiliser un gestionnaire de trafic pour acheminer les requêtes entre les deux centres de données et procéder à un basculement en cas de panne.

Cela vous a-t-il été utile ?
(1500 caractères restants)
Merci pour vos suggestions.
Afficher:
© 2015 Microsoft