Azure Stream Analytics tümleştirmesini kullanarak Azure SQL Veritabanı veri akışı (önizleme)

Kullanıcılar artık gerçek zamanlı akış verilerini doğrudan Azure SQL Veritabanı veritabanından bir tabloya alabilir, işleyebilir, görüntüleyebilir ve analiz edebilir. Azure Stream Analytics'i kullanarak Azure portal bunu yapar. Bu deneyim bağlı araba, uzaktan izleme, sahtekarlık algılama ve daha fazlası gibi çok çeşitli senaryolara olanak tanır. Azure portal bir olay kaynağı (Event Hub/IoT Hub) seçebilir, gelen gerçek zamanlı olayları görüntüleyebilir ve olayları depolamak için bir tablo seçebilirsiniz. Gelen olayları dönüştürmek ve bunları seçili tabloda depolamak için portalda Azure Stream Analytics Sorgu Dili sorguları da yazabilirsiniz. Bu yeni giriş noktası, Stream Analytics'te zaten var olan oluşturma ve yapılandırma deneyimlerine ek olarak sağlanır. Bu deneyim, veritabanınızın bağlamından başlayarak hızla bir Stream Analytics işi ayarlamanıza ve Azure SQL Veritabanı ile Stream Analytics deneyimlerindeki veritabanı arasında sorunsuz bir şekilde gezinmenize olanak tanır.

Stream Analytics flow

Önemli avantajlar

  • Minimum bağlam geçişi: Portaldaki Azure SQL Veritabanı veritabanından başlayıp başka bir hizmete geçmeden gerçek zamanlı verileri tabloya almaya başlayabilirsiniz.
  • Daha az sayıda adım: Veritabanınızın ve tablonuzun bağlamı, Stream Analytics işini önceden yapılandırmak için kullanılır.
  • Önizleme verileriyle ek kullanım kolaylığı: Seçilen tablo bağlamında olay kaynağından (Event Hub/IoT Hub) gelen verileri önizleme

Önemli

Azure Stream Analytics işi Azure SQL Veritabanı, Azure SQL Yönetilen Örneği veya Azure Synapse Analytics'e çıkış yapabilir. Daha fazla bilgi için bkz . Çıkışlar.

Önkoşullar

Bu makaledeki adımları tamamlamak için aşağıdaki kaynaklar gereklidir:

Stream analytics tümleştirmesini yapılandırma

  1. Azure portalında oturum açın.

  2. Akış verilerinizi almak istediğiniz veritabanına gidin. Akış analizi (önizleme) seçeneğini belirleyin.

    Stream Analytics

  3. Akış verilerinizi bu veritabanına almaya başlamak için Oluştur'u seçip akış işinize bir ad verin ve ardından İleri: Giriş'i seçin.

    configure Stream Analytics job basics

  4. Olay kaynağı ayrıntılarınızı girin ve ardından İleri: Çıkış'ı seçin.

    • Giriş türü: Olay Hub'ı/IoT Hub

    • Giriş diğer adı: Olay kaynağınızı tanımlamak için bir ad girin

    • Abonelik: Azure SQL Veritabanı aboneliğiyle aynı

    • Event Hub ad alanı: Ad alanının adı

    • Olay Hub'ı adı: Seçili ad alanındaki olay hub'ının adı

    • Olay Hub'ı ilke adı (Yeni oluşturmak için varsayılan): İlke adı verin

    • Event Hub tüketici grubu (Yeni oluşturmak için varsayılan): Bir tüketici grubu adı verin

      Buradan oluşturduğunuz her yeni Azure Stream Analytics işi için bir tüketici grubu ve ilke oluşturmanızı öneririz. Tüketici grupları yalnızca beş eşzamanlı okuyucuya izin verir, bu nedenle her iş için ayrılmış bir tüketici grubu sağlamak, bu sınırın aşılmasından kaynaklanacak hataları önler. Ayrılmış ilke, anahtarınızı döndürmenize veya diğer kaynakları etkilemeden izinleri iptal etmenizi sağlar.

      configure Stream Analytics job output

  5. Akış verilerinizi almak istediğiniz tabloyu seçin. İşiniz bittiğinde Oluştur'u seçin.

    • Kullanıcı adı, Parola: SQL sunucu kimlik doğrulaması için kimlik bilgilerinizi girin. Doğrula'yı seçin.

    • Tablo: Yeni oluştur'u veya Var olanı kullan'ı seçin. Bu akışta Oluştur'u seçelim. Bu işlem, stream Analytics işini başlattığınızda yeni bir tablo oluşturur.

      create Stream Analytics job

  6. Aşağıdaki ayrıntıları içeren bir sorgu sayfası açılır:

    • Veri almak istediğiniz Giriş (giriş olayları kaynağı)

    • Dönüştürülen verileri depolayacak Çıktınız (çıkış tablosu)

    • SELECT deyimiyle örnek SAQL sorgusu .

    • Giriş önizlemesi: Giriş olayları kaynağından en son gelen verilerin anlık görüntüsünü gösterir.

      • Verilerinizdeki serileştirme türü otomatik olarak algılanır (JSON/CSV). Bunu el ile JSON/CSV/AVRO olarak da değiştirebilirsiniz.
      • Gelen verilerin önizlemesini Tablo biçiminde veya Ham biçimde görüntüleyebilirsiniz.
      • Gösterilen verileriniz güncel değilse, en son olayları görmek için Yenile'yi seçin.
      • Sorgunuzu belirli bir gelen olay aralığına göre test etmek için Zaman aralığı seçin'i seçin.
      • Örnek JSON/CSV dosyasını karşıya yükleyerek sorgunuzu test etmek için Upload örnek girişi seçin. SAQL sorgusunu test etme hakkında daha fazla bilgi için bkz. Örnek verilerle Azure Stream Analytics işini test etme.

      test query

    • Test sonuçları: Test sorgusu'yu seçtiğinizde akış sorgunuzun sonuçlarını görebilirsiniz

      test results

    • Test sonuçları şeması: Test sonrasında akış sorgunuzun sonuçlarının şemasını gösterir. Test sonuçları şemasının çıkış şemanızla eşleştiğinden emin olun.

      test results schema

    • Çıkış şeması: Bu, 5. adımda seçtiğiniz tablonun şemasını içerir (yeni veya var olan).

      • Yeni oluştur: 5. adımda bu seçeneği belirlediyseniz, akış işini başlatana kadar şemayı henüz görmezsiniz. Yeni tablo oluştururken uygun tablo dizinini seçin. Tablo dizini oluşturma hakkında daha fazla bilgi için bkz. Kümelenmiş ve Kümelenmemiş Dizinler Açıklandı.
      • Var olanı kullan: 5. adımda bu seçeneği belirlediyseniz, seçili tablonun şemasını görürsünüz.
  7. Sorguyu & yazmayı tamamladıktan sonra Sorguyu kaydet'i seçin. Dönüştürülmüş verileri SQL tablosuna almaya başlamak için Stream Analytics işini başlat'ı seçin. Aşağıdaki alanları tamamladıktan sonra işi başlatın .

    • Çıkış başlangıç zamanı: Bu, işin ilk çıkışının zamanını tanımlar.

      • Şimdi: İş şimdi başlayacak ve yeni gelen verileri işleyecek.
      • Özel: İş şimdi başlayacak ancak belirli bir zaman noktasından (geçmişte veya gelecekte olabilir) verileri işleyecek. Daha fazla bilgi için bkz. Azure Stream Analytics işini başlatma.
    • Akış birimleri: Azure Stream Analytics, verileri hizmete işlemek için gereken akış birimi sayısına göre fiyatlanır. Daha fazla bilgi için bkz. Azure Stream Analytics fiyatlandırması.

    • Çıktı verileri hata işleme:

      • Yeniden deneme: Bir hata oluştuğunda Azure Stream Analytics, yazma işlemi başarılı olana kadar olayı süresiz olarak yeniden yazmaya devam eder. Yeniden denemeler için zaman aşımı yoktur. Sonunda, izleyen tüm olayların yeniden denenen olay tarafından işlenmesi engellenir. Bu seçenek varsayılan çıkış hata işleme ilkesidir.
      • Bırakma: Azure Stream Analytics, veri dönüştürme hatasına neden olan tüm çıkış olaylarını bırakır. Bırakılan olaylar daha sonra yeniden işleme için kurtarılamaz. Çıkış hatası işleme ilkesi yapılandırmasından bağımsız olarak tüm geçici hatalar (örneğin, ağ hataları) yeniden deneniyor.
    • çıkış ayarlarını SQL Veritabanı: Tabloya birden çok yazıcı içeren tam paralel topolojiyi etkinleştirmek için önceki sorgu adımınızın bölümleme düzenini devralma seçeneği. Daha fazla bilgi için bkz. Azure SQL Veritabanı için Azure Stream Analytics çıkışı.

    • Maksimum toplu iş sayısı: Her toplu ekleme işlemiyle gönderilen kayıt sayısı için önerilen üst sınır.
      Çıkış hatası işleme hakkında daha fazla bilgi için bkz. Azure Stream Analytics'te çıkış hata ilkeleri.

      start job

  8. İşi başlattıktan sonra, listede Çalışıyor işini görürsünüz ve aşağıdaki eylemleri gerçekleştirebilirsiniz:

    • İşi başlatma/durdurma: İş çalışıyorsa, işi durdurabilirsiniz. İş durdurulursa, işi başlatabilirsiniz.

    • İşi düzenle: Sorguyu düzenleyebilirsiniz. İşte daha fazla değişiklik yapmak istiyorsanız, daha fazla giriş/çıkış ekleyin ve ardından işi Stream Analytics'te açın. İş çalışırken Düzenle seçeneği devre dışı bırakılır.

    • Çıktı tablosunu önizleme: SQL sorgu düzenleyicisinde tablonun önizlemesini görebilirsiniz.

    • Stream Analytics'te aç: İşin izleme ve hata ayıklama ayrıntılarını görüntülemek için işi Stream Analytics'te açın.

      stream analytics jobs

Sonraki adımlar