Azure Stream Analytics'den çıkışlar

Bir Azure Stream Analytics işi giriş, sorgu ve çıkışlardan oluşur. Dönüştürülmüş verileri gönderebilirsiniz çeşitli çıkış türleri vardır. Bu makalede, desteklenen Stream Analytics listeledik. Uygulama sorgunuz Stream Analytics INTO yan tümcesini kullanarak çıkışın adına bakın. Sorguya birden çok INTO yan tümcesi ekleyerek iş başına tek bir çıkış veya akış işi başına birden çok çıkış (gerekirse) kullanabilirsiniz.

İş çıkışlarını oluşturmak, düzenlemek Stream Analytics test etmek için Azure portal, Azure PowerShell, .NET API, REST APIve Visual Studio.

Bazı çıkış türleri bölümlendirerek desteklerve çıktı toplu iş boyutları aktarım hızını iyileştirmek için farklılık gösterir. Aşağıdaki tabloda her çıkış türü için desteklenen özellikler yer alır:

Bölümleme

Stream Analytics, diğer çıkışlar dışındaki tüm çıkışlar için bölümleri Power BI. Bölüm anahtarları ve çıkış yazıcılarının sayısı hakkında daha fazla bilgi için ilgilendiğiniz belirli çıkış türüne ilişkin makaleye bakın. Tüm çıkış makaleleri önceki bölümde bağlantılıdır.

Ayrıca, bölümlerin daha gelişmiş ayarlaması için çıkış yazıcılarının sayısı sorgunuza bir (INTO ) yan tümcesi kullanılarak denetlenir ve bu da istenen iş topolojisini elde etmek için INTO <partition count> yararlı olabilir. Çıkış bağdaştırıcınız bölümlemezse, bir giriş bölümde veri olmaması geç varış süresine kadar gecikmeye neden olur. Böyle durumlarda çıkış tek bir yazıcıyla birleştirilir ve bu da işlem hattında performans sorunlarına neden olabilir. Geç varış ilkesi hakkında daha fazla bilgi edinmek için bkz. olay Azure Stream Analytics dikkat edilmesi gerekenler.

Çıkış toplu iş boyutu

Tüm çıkışlar toplu işlemi destekler, ancak yalnızca bazıları toplu iş boyutunu açıkça destekler. Azure Stream Analytics olayları işleme ve çıkışlara yazma için değişken boyutlu toplu işler kullanır. Genellikle Stream Analytics altyapısı aynı anda bir ileti yazmaz ve verimlilik için toplu işler kullanır. Hem gelen hem de giden olayların oranı yüksek olduğunda, Stream Analytics toplu işler kullanır. Çıkış hızı düşük olduğunda, gecikme süresini düşük tutmak için daha küçük toplu işler kullanır.

Parquet çıkış toplu işleme penceresi özellikleri

Bir Azure Resource Manager dağıtım veya REST API kullanırken, iki toplu işlem penceresi özelliği:

1. timeWindow

   Toplu iş başına en uzun bekleme süresi. Değer bir Timespan dizesi olmalıdır. Örneğin, iki dakika için "00:02:00". Bu sürenin ardından, minimum satır gereksinimi karşılanmazsa bile toplu iş çıkışa yazılır. Varsayılan değer 1 dakika, izin verilen maksimum değer ise 2 saattir. Blob çıkışınız yol deseni sıklığına sahipse bekleme süresi bölüm zaman aralığından yüksek olamaz.

2. sizeWindow

   Toplu iş başına minimum satır sayısı. Parquet için her toplu iş yeni bir dosya oluşturur. Geçerli varsayılan değer 2.000 satır ve izin verilen maksimum değer 10.000 satırdır.

Bu toplu işlem penceresi özellikleri yalnızca API sürüm 2017-04-01-preview tarafından de destekler. Aşağıda bir çağrı çağrısı için JSON yükü REST API verilmiştir:

"type": "stream",
      "serialization": {
        "type": "Parquet",
        "properties": {}
      },
      "timeWindow": "00:02:00",
      "sizeWindow": "2000",
      "datasource": {
        "type": "Microsoft.Storage/Blob",
        "properties": {
          "storageAccounts" : [
          {
            "accountName": "{accountName}",
            "accountKey": "{accountKey}",
          }
          ],

Sonraki adımlar