Azure SQL veritabanında verileri dönüştürmek ve depolamak için Azure Stream Analytics kod içermeyen düzenleyiciyi kullanma

Bu makalede, bir Event Hubs örneğinden (olay hub'ı) verileri sürekli okuyan, verileri dönüştüren ve ardından sonuçları bir Azure SQL veritabanına yazan stream analytics işini kolayca oluşturmak için kod düzenleyicisini nasıl kullanabileceğiniz açıklanmaktadır.

Önkoşullar

Azure Event Hubs ve Azure SQL Veritabanı kaynaklarınız genel erişime açık olmalı ve bir güvenlik duvarının arkasında olmamalıdır veya Azure Sanal Ağ güvenliği sağlanmamalıdır. Event Hubs'ınızdaki veriler JSON, CSV veya Avro biçiminde seri hale getirilmelidir.

Bu makaledeki adımları denemek istiyorsanız aşağıdaki adımları izleyin.

• Henüz bir olay hub'ına sahip değilseniz bir olay hub'ı oluşturun. Olay hub'ında veri oluşturma. Event Hubs Örneği sayfasında, soldaki menüden Veri oluştur (önizleme) öğesini seçin, Veri Kümesi için stok verileri'ni seçin ve ardından olay hub'ına örnek veriler göndermek için Gönder'i seçin. Bu makaledeki adımları test etmek istiyorsanız bu adım gereklidir.

  

• Azure SQL veritabanı oluşturma. Veritabanını oluştururken dikkat edilmesi gereken birkaç önemli nokta aşağıdadır.

  1. Temel Bilgiler sayfasında Sunucu için yeni oluştur'u seçin. Ardından, SQL Veritabanı sunucusu oluştur sayfasında SQL kimlik doğrulamasını kullan'ı seçin ve yönetici kullanıcı kimliği ile parolayı belirtin.

  2. Ağ sayfasında şu adımları izleyin:

     1. Genel uç noktayı etkinleştirin.
     2. Azure hizmetlerinin ve kaynaklarının bu sunucuya erişmesine izin ver için Evet'i seçin.
     3. Geçerli istemci IP adresi ekle için Evet'i seçin.

  3. Ek ayarlar sayfasında Var olan verileri kullan için Yok'a tıklayın.

  4. Makalede, Veritabanını sorgulama ve Kaynakları temizleme bölümlerindeki adımları atlayın.

  5. Adımları test etmek istiyorsanız, Sorgu düzenleyicisini (önizleme) kullanarak SQL veritabanında bir tablo oluşturun.

     create table stocks (
         symbol varchar(4),
         price decimal
     )
     

Stream Analytics işi oluşturmak için kod içermeyen düzenleyiciyi kullanma

Bu bölümde kod içermeyen düzenleyiciyi kullanarak bir Azure Stream Analytics işi oluşturacaksınız. İş bir Event Hubs örneğinden (olay hub'ı) veri akışını dönüştürür ve sonuç verilerini bir Azure SQL veritabanında depolar.

1. Azure portalında olay hub'ınızın Event Hubs Örneği sayfasına gidin.

2. Soldaki menüden Özellikler>İşlem Verileri'ni seçin ve ardından Verileri SQL veritabanı kartına dönüştür ve depola kartında Başlat'ı seçin.

   

3. Stream Analytics işi için bir ad girin ve Oluştur'u seçin. Sağ tarafta Event Hubs penceresinin olduğu Stream Analytics iş diyagramını görürsünüz.

   

4. Olay hub'ı penceresinde Serileştirme ve Kimlik Doğrulama modu ayarlarını gözden geçirin ve Bağlan'ı seçin.

   

5. Bağlantı başarıyla kurulduğunda ve Event Hubs örneğinizde verileriniz olduğunda iki şey görürsünüz:

   • Giriş verilerinde bulunan alanlar. Alan ekle'yi seçebilir veya bir alanın yanındaki üç nokta simgesini seçerek türünü kaldırabilir, yeniden adlandırabilir veya değiştirebilirsiniz.

     

   • Diyagram görünümünün altındaki Veri önizleme tablosundaki gelen verilerin canlı örneği. Düzenli aralıklarla otomatik olarak yenilenir. Örnek giriş verilerinin statik görünümünü görmek için Akış önizlemesini duraklat'ı seçebilirsiniz.

     

6. Verileri toplamak için Gruplandırma ölçütü kutucuğunu seçin. Yapılandırmaya göre gruplandır panelinde, Gruplandırmak istediğiniz alanı Zaman penceresiyle birlikte belirtebilirsiniz.

   Aşağıdaki örnekte fiyat ve simge ortalaması kullanılmıştır.

   

7. Veri önizleme bölümünde adımın sonuçlarını doğrulayabilirsiniz.

   

8. Alanları yönet kutucuğunu seçin. Alanları yönet yapılandırma panelinde Alan ekle ->İçeri Aktarılan Şema -> alan'ı seçerek çıktısını almak istediğiniz alanları seçin.

   Tüm alanları eklemek istiyorsanız Tüm alanları ekle'yi seçin. Alan eklerken çıkış için farklı bir ad belirtebilirsiniz. Örneğin, AVG_Value için Value. Seçimleri kaydettikten sonra, Verileri Veri önizleme bölmesinde görürsünüz.

   Aşağıdaki örnekte Sembol ve AVG_Value seçilmiştir. Simge simgeyle eşlenir ve AVG_Value fiyatla eşlenir.

   

9. SQL kutucuğunu seçin. SQL Veritabanı yapılandırma panelinde gerekli parametreleri doldurun ve bağlanın. Tablonun otomatik olarak seçilmesi için Varolan tabloyu yükle'yi seçin. Aşağıdaki örnekte, [dbo].[stocks] seçilir. Ardından Bağlan'ı seçin.

   Not

   Yazmayı seçtiğiniz tablonun şeması, veri önizlemenizin oluşturduğu alan sayısı ve türleriyle tam olarak eşleşmelidir.

   

10. Veri önizleme bölmesinde, SQL veritabanında alınan veri önizlemesini görürsünüz.

    

11. Kaydet'i ve ardından Stream Analytics işini başlat'ı seçin.

    

12. İşi başlatmak için şunları belirtin:

    • İşin çalıştığı Akış Birimi (SU) sayısı. SU'lar, işe ayrılan işlem ve bellek miktarını temsil eder. Üç ile başlayıp gerektiği gibi ayarlama yapmanızı öneririz.

    • Çıktı veri hatası işleme – Bir işin hedefinize çıkışı veri hataları nedeniyle başarısız olduğunda istediğiniz davranışı belirtmenize olanak tanır. Varsayılan olarak, yazma işlemi başarılı olana kadar işiniz yeniden denenir. Bu tür çıkış olaylarını bırakmayı da seçebilirsiniz.

      

13. Başlat'ı seçtikten sonra, iş iki dakika içinde çalışmaya başlar. Alt bölmede ölçümler panelinin açık olduğunu görürsünüz. Bu panelin güncelleştirilmiş olması zaman alır. Grafiği yenilemek için panelin sağ üst köşesindeki Yenile'yi seçin. Web tarayıcısının ayrı bir sekmesinde veya penceresinde sonraki adıma geçin.

    

    İşi Stream Analytics işleri sekmesindeki İşlem Verileri bölümünün altında da görebilirsiniz. İzlemek için Ölçümleri aç'ı seçin veya gerektiğinde durdurup yeniden başlatın.

    

14. Portalda olay hub'ınıza ayrı bir tarayıcı penceresinde veya sekmesinde gidin ve örnek hisse senedi verilerini yeniden gönderin (önkoşullarda yaptığınız gibi). Event Hubs Örneği sayfasında, soldaki menüden Veri oluştur (önizleme) öğesini seçin, Veri Kümesi için stok verileri'ni seçin ve ardından olay hub'ına örnek veriler göndermek için Gönder'i seçin. Ölçümler panelinin güncelleştirildiğini görmek birkaç dakika sürer.

15. Azure SQL veritabanına eklenen kayıtları görmeniz gerekir.

    

Event Hubs Coğrafi çoğaltma özelliğini kullanırken dikkat edilmesi gerekenler

Azure Event Hubs kısa süre önce genel önizlemede Coğrafi Çoğaltma özelliğini başlattı. Bu özellik, Azure Event Hubs'ın Coğrafi Olağanüstü Durum Kurtarma özelliğinden farklıdır.

Yük devretme türü Zorlamalı olduğunda ve çoğaltma tutarlılığı Zaman Uyumsuz olduğunda, Stream Analytics işi bir Azure Event Hubs çıkışının tam olarak bir kez çıkışını garanti etmez.

Azure Stream Analytics, bir olay hub'ı çıktısı olan bir üretici olarak yük devretme süresi ve birincil ile ikincil arasında çoğaltma gecikmesinin yapılandırılan maksimum gecikmeye ulaşması durumunda Event Hubs tarafından azaltma sırasında iş üzerinde filigran gecikmesi gözlemlenebilir.

Azure Stream Analytics, Event Hubs giriş olarak tüketici olarak yük devretme süresi boyunca iş üzerinde filigran gecikmesi gözlemler ve yük devretme tamamlandıktan sonra verileri atlayabilir veya yinelenen verileri bulabilir.

Bu uyarılar nedeniyle, Event Hubs yük devretme tamamlandıktan hemen sonra Stream Analytics işini uygun başlangıç zamanıyla yeniden başlatmanızı öneririz. Ayrıca Event Hubs Coğrafi çoğaltma özelliği genel önizleme aşamasında olduğundan, bu noktada üretim Stream Analytics işleri için bu desenin kullanılmasını önermiyoruz. Event Hubs Coğrafi çoğaltma özelliği genel kullanıma sunulmadan önce geçerli Stream Analytics davranışı geliştirilecektir ve Stream Analytics üretim işlerinde kullanılabilir.

Sonraki adımlar

Azure Stream Analytics ve oluşturduğunuz işi izleme hakkında daha fazla bilgi edinin.

• Azure Stream Analytics'e giriş
• Azure portalı ile Stream Analytics işini izleme