Program aracılığıyla Stream Analytics iş İzleyicisi oluşturma

Bu makalede bir Stream Analytics işi için izlemenin nasıl etkinleştirileceği gösterilmektedir. REST API 'Leri, Azure SDK veya PowerShell aracılığıyla oluşturulan Stream Analytics işlerin varsayılan olarak etkin izleme özelliği yoktur. İşin Izleyici sayfasına gidip Etkinleştir düğmesine tıklayarak ve bu makaledeki adımları izleyerek bu işlemi otomatikleştirebileceğiniz Azure portal el ile etkinleştirebilirsiniz. İzleme verileri, Stream Analytics işiniz için Azure portal ölçüm alanında görünür.

Önkoşullar

Bu işleme başlamadan önce, aşağıdaki önkoşullara sahip olmanız gerekir:

• Visual Studio 2019 veya 2015
• Azure .NET SDK indirildi ve yüklendi
• İzlemenin etkinleştirilmesi gereken mevcut bir Stream Analytics işi

Proje oluşturma

1. Visual Studio C# .NET konsol uygulaması oluşturun.

2. Paket Yöneticisi konsolunda, NuGet paketlerini yüklemek için aşağıdaki komutları çalıştırın. Birincisi Azure Stream Analytics Management .NET SDK 'dır. İkinci bir tane, izlemeyi etkinleştirmek için kullanılacak Azure Izleyici SDK 'sına sahiptir. Son bir kimlik doğrulaması için kullanılacak Azure Active Directory istemcsahiptir.

   Install-Package Microsoft.Azure.Management.StreamAnalytics
   Install-Package Microsoft.Azure.Insights -Pre
   Install-Package Microsoft.IdentityModel.Clients.ActiveDirectory
   

3. Aşağıdaki appSettings bölümünü App.config dosyasına ekleyin.

   <appSettings>
     <!--CSM Prod related values-->
     <add key="ResourceGroupName" value="RESOURCE GROUP NAME" />
     <add key="JobName" value="YOUR JOB NAME" />
     <add key="StorageAccountName" value="YOUR STORAGE ACCOUNT"/>
     <add key="ActiveDirectoryEndpoint" value="https://login.microsoftonline.com/" />
     <add key="ResourceManagerEndpoint" value="https://management.azure.com/" />
     <add key="WindowsManagementUri" value="https://management.core.windows.net/" />
     <add key="AsaClientId" value="1950a258-227b-4e31-a9cf-717495945fc2" />
     <add key="RedirectUri" value="urn:ietf:wg:oauth:2.0:oob" />
     <add key="SubscriptionId" value="YOUR AZURE SUBSCRIPTION ID" />
     <add key="ActiveDirectoryTenantId" value="YOUR TENANT ID" />
   </appSettings>
   

   SubscriptionID ve activedirectorytenantıd değerlerini Azure aboneliğiniz ve kiracı kimlikleri ile değiştirin. Aşağıdaki PowerShell cmdlet 'ini çalıştırarak bu değerleri alabilirsiniz:

   Get-AzureAccount
   

4. Aşağıdaki using bildirimlerini projedeki kaynak dosyasına (Program.cs) ekleyin.

     using System;
     using System.Configuration;
     using System.Threading;
     using Microsoft.Azure;
     using Microsoft.Azure.Management.Insights;
     using Microsoft.Azure.Management.Insights.Models;
     using Microsoft.Azure.Management.StreamAnalytics;
     using Microsoft.Azure.Management.StreamAnalytics.Models;
     using Microsoft.IdentityModel.Clients.ActiveDirectory;
   

5. Kimlik doğrulama Yardımcısı yöntemi ekleyin.

   public static string GetAuthorizationHeader()
   {
      AuthenticationResult result = null;
      var thread = new Thread(() =>
      {
         try
         {
             var context = new AuthenticationContext(
                ConfigurationManager.AppSettings["ActiveDirectoryEndpoint"] +
                ConfigurationManager.AppSettings["ActiveDirectoryTenantId"]);
             result = context.AcquireToken(
                 resource: ConfigurationManager.AppSettings["WindowsManagementUri"],
                 clientId: ConfigurationManager.AppSettings["AsaClientId"],
                 redirectUri: new Uri(ConfigurationManager.AppSettings["RedirectUri"]),
                 promptBehavior: PromptBehavior.Always);
         }
         catch (Exception threadEx)
         {
             Console.WriteLine(threadEx.Message);
         }
     });
   
     thread.SetApartmentState(ApartmentState.STA);
     thread.Name = "AcquireTokenThread";
     thread.Start();
     thread.Join();
   
     if (result != null)
     {
         return result.AccessToken;
     }
         throw new InvalidOperationException("Failed to acquire token");
   }
   

Yönetim istemcileri oluşturma

Aşağıdaki kod, gerekli değişkenleri ve yönetim istemcilerini ayarlar.

 string resourceGroupName = "<YOUR AZURE RESOURCE GROUP NAME>";
 string streamAnalyticsJobName = "<YOUR STREAM ANALYTICS JOB NAME>";

 // Get authentication token
 TokenCloudCredentials aadTokenCredentials =
     new TokenCloudCredentials(
         ConfigurationManager.AppSettings["SubscriptionId"],
         GetAuthorizationHeader());

 Uri resourceManagerUri = new
 Uri(ConfigurationManager.AppSettings["ResourceManagerEndpoint"]);

 // Create Stream Analytics and Insights management client
 StreamAnalyticsManagementClient streamAnalyticsClient = new
 StreamAnalyticsManagementClient(aadTokenCredentials, resourceManagerUri);
 InsightsManagementClient insightsClient = new
 InsightsManagementClient(aadTokenCredentials, resourceManagerUri);

Mevcut bir Stream Analytics işi için izlemeyi etkinleştir

Aşağıdaki kod, mevcut bir Stream Analytics işi için izlemeyi mümkün bir şekilde sunar. Kodun ilk bölümü, belirli bir Stream Analytics iş hakkında bilgi almak için Stream Analytics hizmetine karşı bir GET isteği gerçekleştirir. Stream Analytics işi için izlemeyi etkinleştirmek üzere öngörülere bir PUT isteği gönderen ve kodun ikinci yarısında bulunan ID ÖZELLIĞINI (Get isteğinden alınan) bir parametre olarak kullanır.

// Get an existing Stream Analytics job
 JobGetParameters jobGetParameters = new JobGetParameters()
 {
     PropertiesToExpand = "inputs,transformation,outputs"
 };
 JobGetResponse jobGetResponse = streamAnalyticsClient.StreamingJobs.Get(resourceGroupName, streamAnalyticsJobName, jobGetParameters);

// Enable monitoring
ServiceDiagnosticSettingsPutParameters insightPutParameters = new ServiceDiagnosticSettingsPutParameters()
{
        Properties = new ServiceDiagnosticSettings()
       {
           StorageAccountName = "<YOUR STORAGE ACCOUNT NAME>"
       }
};
insightsClient.ServiceDiagnosticSettingsOperations.Put(jobGetResponse.Job.Id, insightPutParameters);

Destek alın

Daha fazla yardım için, Azure Stream Analytics Için Microsoft Q&soru sayfasınıdeneyin.

Sonraki adımlar

• Azure Stream Analytics giriş
• Azure Akış Analizi'ni kullanmaya başlama
• Azure Akış Analizi işlerini ölçeklendirme
• Azure Akış Analizi Sorgu Dili Başvurusu
• Azure Akış Analizi Yönetimi REST API'si Başvurusu