Azure Stream Analytics'ten Azure Veri Gezgini'a veri alma

Önemli

Bu bağlayıcı, Microsoft Fabric'teki Gerçek Zamanlı Zeka'da kullanılabilir. Aşağıdaki özel durumlar için bu makaledeki yönergeleri kullanın:

• Gerekirse, KQL veritabanı oluşturma başlığındaki yönergeleri kullanarak veritabanları oluşturun.
• Gerekirse, Boş tablo oluşturma başlığındaki yönergeleri kullanarak tablolar oluşturun.
• Kopyalama URI'sindeki yönergeleri kullanarak sorgu veya alma URI'lerini alın.
• KQL sorgu kümesinde sorgu çalıştırma.

Azure Veri Gezgini, Azure Stream Analytics'ten veri alımını destekler. Azure Stream Analytics, birden çok kaynaktan gelen yüksek hacimli hızlı akış verilerini aynı anda işlemek için tasarlanmış gerçek zamanlı bir analiz ve karmaşık olay işleme altyapısıdır.

Azure Stream Analytics işi giriş kaynağı, dönüştürme sorgusu ve çıkış bağlantısından oluşur. Azure portalını, Azure Resource Manager (ARM) şablonlarını, Azure PowerShell'i, .NET API'sini, REST API'sini, Visual Studio'yu ve Kod düzenleyicisi olmayan Stream Analytics'i kullanarak Stream Analytics işleri oluşturabilir, düzenleyebilir ve test edebilirsiniz.

Bu makalede, stream analytics işini kullanarak bir olay hub'ından veri toplamayı ve Azure portalını veya ARM şablonunu kullanarak Azure Veri Gezgini kümenize göndermeyi öğreneceksiniz.

Önkoşullar

• Küme , veritabanı ve tablo oluşturma.

• Azure Stream Analytics öğreticisinin aşağıdaki bölümlerini kullanarak bir olay hub'ı oluşturun:

  • Olay Hub’ı oluşturma
  • Olay hub'ına erişim izni verme ve bağlantı dizesi

  İpucu

  Test için Microsoft İndirme Merkezi'nden telefon araması olay oluşturucu uygulamasını indirmenizi veya GitHub'dan kaynak kodunu almanızı öneririz. Azure Stream Analytics işini ayarlarken, olay hub'ından veri çekecek ve Azure Veri Gezgini çıkış bağlayıcısına geçirecek şekilde yapılandıracaksınız.

Azure Veri Gezgini çıkış bağlantısı oluşturma

Azure portalını veya ARM şablonunu kullanarak Stream Analytics işi için Azure Veri Gezgini çıkışı oluşturmak için aşağıdaki adımları kullanın. Bağlantı, Stream Analytics işi tarafından belirli bir Azure Veri Gezgini tablosuna veri göndermek için kullanılır. Oluşturulduktan ve iş çalıştırıldıktan sonra, işe akan veriler belirtilen hedef tabloya alınır.

Önemli

• Azure Veri Gezgini çıkış bağlayıcısı yalnızca Yönetilen Kimlik kimlik doğrulamasını destekler. Bağlayıcı oluşturmanın bir parçası olarak, Azure Stream Analytics işi yönetilen kimliğine veritabanı izleyicisi ve veritabanı alma izinleri verilir.
• Azure Veri Gezgini çıkış bağlayıcısını ayarlarken hedef kümeyi, veritabanını ve tablo adını belirtirsiniz. Alımın başarılı olması için Azure Stream Analytics sorgusunda tanımlanan tüm sütunların Azure Veri Gezgini tablosundaki sütun adları ve türleriyle eşleşmesi gerekir. Sütun adları büyük/küçük harfe duyarlıdır ve herhangi bir sırada olabilir. Azure Stream Analytics sorgusunda Azure Veri Gezgini tablosundaki sütunlarla eşleşmeyen sütunlar varsa bir hata oluşur.

Not

• Tüm Azure Stream Analytics girişleri desteklenir. Bağlayıcı girişleri CSV biçimine dönüştürür ve ardından verileri belirtilen Azure Veri Gezgini tablosuna aktarır.
• Azure Veri Gezgini, veri alımı için alım işlemini iyileştirmek üzere tasarlanmış bir toplama (toplu işlem) ilkesine sahiptir. Varsayılan olarak, ilke varsayılan olarak 5 dakika, 1000 öğe veya 1 GB veri olarak yapılandırılır, bu nedenle gecikme yaşayabilirsiniz. Toplama seçeneklerini yapılandırma hakkında bilgi için bkz . toplu işlem ilkesi.

Azure portalı

Başlamadan önce mevcut bir Stream Analytics işiniz olduğundan emin olun veya yeni bir iş oluşturun ve azure Veri Gezgini bağlantınızı oluşturmak için aşağıdaki adımları kullanın.

1. Azure Portal’ında oturum açın.

2. Azure portalından Tüm kaynaklar'ı açın ve Stream Analytics işinizi seçin.

3. İş topolojisi'nin altında Çıkışlar'ı seçin.

4. Azure Veri Gezgini Ekle'yi>seçin.

   

5. Aşağıdaki bilgileri kullanarak çıkış formunu doldurun ve Kaydet'i seçin.

   Not

   Kümenizi ve veritabanınızı belirtmek için aşağıdaki seçenekleri kullanabilirsiniz:

   • Abonelik: Aboneliklerinizden Azure Veri Gezgini seç'i seçin, aboneliğinizi seçin ve ardından kümenizi ve veritabanınızı seçin.
   • El ile: Azure Veri Gezgini ayarlarını el ile sağla'yı seçin, küme URI'sini ve veritabanını belirtin.

   Özellik adı	Açıklama
   Çıktı diğer adı	Sorgu çıkışını bu veritabanına yönlendirmek için sorgularda kullanılan kolay ad.
   Abonelik	Kümenizin bulunduğu Azure aboneliğini seçin.
   Küme	Kümenizi tanımlayan benzersiz ad. Girdiğiniz küme adının sonuna [bölge].servicebus.windows.net etki alanı adı eklenir. Ad yalnızca küçük harf ve sayı içerebilir. 4 ile 22 karakter arası olmalıdır.
   Küme URI'si	Kümenizin veri alımı URI'si. Azure Veri Gezgini veya Azure Synapse Veri Gezgini veri alımı uç noktaları için URI belirtebilirsiniz.
   Veritabanı	Çıktınızı gönderdiğiniz veritabanının adı. Veritabanı adı küme içinde benzersiz olmalıdır.
   Kimlik Doğrulaması	Kümenizin diğer Microsoft Entra korumalı kaynaklara kolayca erişmesini sağlayan bir Microsoft Entra yönetilen kimliği. Kimlik Azure platformu tarafından yönetilir ve herhangi bir gizli dizi sağlamanızı veya düzenli olarak değiştirmenizi gerektirmez. Yönetilen kimlik yapılandırması, kümeniz için müşteri tarafından yönetilen anahtarları kullanmanıza olanak tanır.
   Tablo	Çıktınızı gönderdiğiniz tablonun adı. Azure Stream Analytics çıkışındaki sütun adları ve veri türleri, Azure Veri Gezgini tablosunun şemasıyla eşleşmelidir.

   

Azure Resource Manager şablonu

Aşağıdaki örnekte, Azure Veri Gezgini çıkış bağlayıcısı eklemeye yönelik bir Azure Resource Manager şablonu gösterilmektedir. Bağlayıcınızı oluşturmak için şablonu Azure portalında düzenleyebilir ve dağıtabilirsiniz.

{
    "$schema": "http://schema.management.azure.com/schemas/2015-01-01/deploymentTemplate.json#",
    "contentVersion": "1.0.0.0",
    "parameters": {
        "streamingJobName": {
            "type": "string",
            "defaultValue": "streamingjob"
        },
        "eventHubNamespace": {
            "type": "string"
        },
        "eventHubKey": {
            "type": "securestring"
        },
        "eventHubName": {
            "type": "string"
        },
        "eventHubConsumerGroupName": {
            "type": "string"
        },
        "streamingUnits": {
            "type": "int",
            "defaultValue": 3
        },
        "ADXClusterUri": {
            "type": "string"
        },
        "ADXDatabaseName": {
            "type": "string"
        },
        "ADXTableName": {
            "type": "string"
        }
    },
    "resources": [
        {
            "apiVersion": "2017-04-01-preview",
            "name": "[parameters('streamingJobName')]",
            "location": "[resourceGroup().location]",
            "type": "Microsoft.StreamAnalytics/StreamingJobs",
            "identity": {
                "type": "systemAssigned"
            },
            "properties": {
                "sku": {
                    "name": "standard"
                },
                "eventsOutOfOrderPolicy": "drop",
                "eventsOutOfOrderMaxDelayInSeconds": 10,
                "compatibilityLevel": "1.2",
                "outputStartMode": "JobStartTime",
                "inputs": [
                    {
                        "name": "inputEventHub",
                        "properties": {
                            "type": "stream",
                            "serialization": {
                                "type": "JSON",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.ServiceBus/EventHub",
                                "properties": {
                                    "serviceBusNamespace": "[parameters('eventHubNamespace')]",
                                    "sharedAccessPolicyName": "RootManageSharedAccessKey",
                                    "sharedAccessPolicyKey": "[parameters('eventHubKey')]",
                                    "eventHubName": "[parameters('eventHubName')]",
                                    "consumerGroupName": "[parameters('eventHubConsumerGroupName')]"
                                }
                            }
                        }
                    }
                ],
                "transformation": {
                    "name": "ProcessSampleData",
                    "properties": {
                        "streamingUnits": "[int(parameters('streamingUnits'))]",
                        "query": "select * from inputEventHub"
                    }
                },
                "outputs": [
                    {
                        "name": "output",
                        "properties": {
                            "serialization": {
                                "type": "CSV",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.Kusto/clusters/databases",
                                "properties": {
                                    "cluster": "[parameters('ADXClusterUri')]",
                                    "table": "[parameters('ADXTableName')]",
                                    "database": "[parameters('ADXDatabaseName')]",
                                    "authenticationMode": "Msi"
                                }
                            }
                        }
                    }
                ]
            }
        }
    ]
}

Not

ARM şablonu kullanarak Azure Veri Gezgini çıkış bağlantısı oluştururken, Azure Veri Gezgini veritabanına Streaming Analytics işi tarafından yönetilen kimlik izinleri el ile verilmelidir.

İlgili içerik

• Azure Veri Gezgini'da verileri sorgulama
• Azure Stream Analytics işlerinden Azure İşlevleri çalıştırma