Aracılığıyla paylaş


Visual Studio'da Azure Stream Analytics için özel .NET seri durumdan çıkarıcılar (Önizleme)

Önemli

Azure Stream Analytics için özel .net seri durumdan çıkarıcı 30 Eylül 2024'te kullanımdan kaldırılacaktır. Bu tarihten sonra özelliği kullanmak mümkün olmayacaktır. Lütfen bu tarihe kadar JSON , AVRO veya CSV yerleşik seri durumdan çıkarıcıya geçin.

Azure Stream Analytics üç veri biçimi için yerleşik desteğe sahiptir: JSON, CSV ve Avro. Özel .NET seri durumdan çıkarıcılarla, hem bulut hem de uç işleri için Protokol AraBelleği, Bond ve diğer kullanıcı tanımlı biçimler gibi diğer biçimlerdeki verileri okuyabilirsiniz.

Bu öğreticide Visual Studio kullanarak Azure Stream Analytics bulut işi için özel bir .NET seri durumdan çıkarıcı oluşturma işlemi gösterilmektedir. Visual Studio Code'da .NET seri durumdan çıkarıcıları oluşturmayı öğrenmek için bkz . Visual Studio Code'da Azure Stream Analytics işleri için .NET seri durumdan çıkarıcılar oluşturma.

Bu öğreticide aşağıdakilerin nasıl yapılacağını öğreneceksiniz:

  • Protokol arabelleği için özel bir seri durumdan çıkarıcı oluşturun.
  • Visual Studio'da bir Azure Stream Analytics işi oluşturun.
  • Stream Analytics işinizi özel seri durumdan çıkarıcıyı kullanacak şekilde yapılandırın.
  • Özel seri durumdan çıkarıcıyı test etmek ve hatalarını ayıklamak için Stream Analytics işinizi yerel olarak çalıştırın.

Önkoşullar

  • Azure aboneliğiniz yoksa ücretsiz hesap oluşturun.

  • Visual Studio 2019 (önerilir) veya Visual Studio 2017'yi yükleyin. Enterprise (Ultimate/Premium), Professional ve Community sürümleri desteklenir. Express sürümü desteklenmez.

  • Visual Studio için Stream Analytics araçlarını yükleyin veya en son sürüme güncelleştirin.

  • Visual Studio'da Cloud Explorer'ı açın ve Azure aboneliğinizde oturum açın.

  • Azure Depolama Hesabınızda bir kapsayıcı oluşturun. Oluşturduğunuz kapsayıcı, Stream Analytics işinizle ilgili varlıkları depolamak için kullanılır. Kapsayıcı bulunan bir depolama hesabınız varsa onu kullanabilirsiniz. Yoksa yeni bir kapsayıcı oluşturmanız gerekir.

Özel seri durumdan çıkarıcı oluşturma

  1. Visual Studio'yu açın ve Dosya > Yeni Proje'yi> seçin. Stream Analytics'i arayın ve Azure Stream Analytics Özel Seri Durumdan Çıkarıcı Projesi (.NET) seçeneğini belirleyin. Projeye Protobuf Seri Durumdan Çıkarıcı gibi bir ad verin.

    Create Visual Studio dotnet standard class library project

  2. Çözüm Gezgini'da Protobuf Seri Durumdan Çıkarıcı projenize sağ tıklayın ve menüden NuGet Paketlerini Yönet'i seçin. Ardından Microsoft.Azure.StreamAnalytics ve Google.Protobuf NuGet paketlerini yükleyin.

  3. MessageBodyProto sınıfını ve MessageBodyDeserializer sınıfını projenize ekleyin.

  4. Protobuf Seri Durumdan Çıkarıcı projesini oluşturun.

Azure Stream Analytics projesi ekleme

  1. Çözüm Gezgini Protobuf Seri Durumdan Çıkarıcı çözümüne sağ tıklayın ve Yeni Proje Ekle'yi > seçin. Azure Stream Analytics Stream Analytics'in> altında Azure Stream Analytics Uygulaması'nı seçin. ProtobufCloudDeserializer olarak adlandırıp Tamam'ı seçin.

  2. ProtobufCloudDeserializer Azure Stream Analytics projesinin altındaki Başvurular'a sağ tıklayın. Projeler'in altında Protobuf Seri Durumdan Çıkarıcı'yı ekleyin. Sizin için otomatik olarak doldurulmalıdır.

Stream Analytics işini yapılandırma

  1. JobConfig.json çift tıklayın. Aşağıdaki ayarlar dışında varsayılan yapılandırmaları kullanın:

    Ayar Önerilen Değer
    Genel Depolama Ayarlar Kaynağı Geçerli hesaptaki veri kaynağını seçin
    Genel Depolama Ayarlar Aboneliği < aboneliğiniz >
    Genel Depolama Ayarlar Depolama Hesabı < depolama hesabınız >
    Özel Kod Depolama Ayarlar Kaynağı Geçerli hesaptaki veri kaynağını seçin
    Özel Kod Depolama Ayarlar Depolama Hesabı < depolama hesabınız >
    Özel Kod Depolama Ayarlar Kapsayıcısı < depolama kapsayıcınız >
  2. Girişler'in altında Input.json çift tıklayın. Aşağıdaki ayarlar dışında varsayılan yapılandırmaları kullanın:

    Ayar Önerilen Değer
    Source Blob Depolama
    Kaynak Geçerli hesaptaki veri kaynağını seçin
    Abonelik < aboneliğiniz >
    Depolama Hesabı < depolama hesabınız >
    Kapsayıcı < depolama kapsayıcınız >
    Olay Serileştirme Biçimi Diğer (Protobuf, XML, özel...)
    Kaynak ASA Proje Başvurusundan veya CodeBehind'den yükleme
    CSharp Derleme Adı ProtobufDeserializer.dll
    Sınıf Adı MessageBodyProto.MessageBodyDeserializer
    Olay Sıkıştırma Türü Hiçbiri
  3. Script.asaql dosyasına aşağıdaki sorguyu ekleyin.

    SELECT * FROM Input
    
  4. Örnek protobuf giriş dosyasını indirin. Girişler klasöründe Input.json sağ tıklayın ve Yerel Giriş Ekle'yi seçin. Ardından local_Input.json çift tıklayın ve aşağıdaki ayarları yapılandırın:

    Ayar Önerilen Değer
    Girdi Diğer Adı Giriş
    Kaynak Türü Veri Akışı
    Olay Serileştirme Biçimi Diğer (Protobuf, XML, özel...)
    CSharp Derleme Adı ProtobufDeserializer.dll
    Sınıf Adı MessageBodyProto.MessageBodyDeserializer
    Yerel Giriş Dosyası Yolu < indirilen örnek protobuf giriş dosyasının dosya yolu>

Stream Analytics işini yürütme

  1. Script.asaql dosyasını açın ve Yerel Olarak Çalıştır'ı seçin.

  2. Stream Analytics Yerel Çalıştırma Sonuçları'nda sonuçları gözlemleyin.

Stream Analytics işiniz için özel seri durumdan çıkarıcıyı başarıyla uyguladınız! Bu öğreticide, özel seri durumdan çıkarıcıyı yerel olarak test ettiniz. Gerçek verileriniz için girişi ve çıkışı düzgün bir şekilde yapılandırırsınız. Ardından, az önce uyguladığınız özel seri durumdan çıkarıcıyı kullanarak işinizi bulutta çalıştırmak için Visual Studio'dan Azure'a iş gönderin.

Seri durumdan çıkarıcınızda hata ayıklama

.NET seri durumdan çıkarıcınızın hatalarını, standart .NET kodunda hata ayıkladığınız gibi yerel olarak da ayıklayabilirsiniz.

  1. ProtobufCloudDeserializer proje adına sağ tıklayın ve başlangıç projesi olarak ayarlayın.

  2. İşlevinize kesme noktaları ekleyin.

  3. Hata ayıklamaya başlamak için F5'e basın. Program beklendiği gibi kesme noktalarında durur.

Kaynakları temizleme

Artık gerekli olmadığında kaynak grubunu, akış işini ve tüm ilgili kaynakları silin. İşin silinmesi, iş tarafından kullanılan akış birimlerinin faturalanmasını önler. İşi gelecekte kullanmayı planlıyorsanız, durdurup daha sonra gerektiğinde yeniden başlatabilirsiniz. Bu işi kullanmaya devam etmeyecekseniz aşağıdaki adımları kullanarak bu öğreticiyle oluşturulan tüm kaynakları silin:

  1. Azure portalında sol taraftaki menüden, Kaynak grupları'nı ve ardından oluşturduğunuz kaynağın adını seçin.

  2. Kaynak grubu sayfanızda, Sil'i seçin, metin kutusuna silinecek kaynağın adını yazın ve ardından Sil'i seçin.

Sonraki adımlar

Bu öğreticide, protokol arabelleği giriş serileştirmesi için özel bir .NET seri durumdan çıkarıcı uygulamayı öğrendiniz. Özel seri durumdan çıkarıcılar oluşturma hakkında daha fazla bilgi edinmek için aşağıdaki makaleye geçin: