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

Önemli

Bu bağlayıcı Microsoft Fabric'teki Gerçek Zamanlı Analiz'de 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.
• Sorguları bir KQL sorgu kümesinde çalıştırın.

Azure Veri Gezgini, Azure Stream Analytics'tenveri 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, Azure Resource Manager (ARM) şablonlarını, Azure PowerShell,.NET API'sini, REST API'yi, 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, bir olay hub'ından veri toplamak ve Azure portal veya ARM şablonu kullanarak Azure Veri Gezgini kümenize göndermek için Stream Analytics işini kullanmayı öğreneceksiniz.

Önkoşullar

• Küme, veritabanı vetablo oluşturun.

• 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 verme ve bir bağlantı dizesi alma

  İ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 kullanarak veya ARM şablonu 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 aktarılır.

Önemli

• Azure Veri Gezgini çıkış bağlayıcısı yalnızca Yönetilen Kimlik kimlik doğrulamasını destekler. Bağlayıcıyı 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ına yönelik bir toplama (toplu işlem) ilkesi vardır ve bu ilke, veri alımı işlemini iyileştirmek için tasarlanmıştır. Varsayılan olarak, ilke varsayılan olarak 5 dakika, 1000 öğe veya 1 GB veri olarak yapılandırılır, bu nedenle bir gecikmeyle karşılaşabilirsiniz. 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 ardından 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 Tüm kaynaklar'ı açın ve Stream Analytics işinizi seçin.

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

4. Azure Veri GezginiEkle'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ı	Description
   Çı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'sini. Azure Veri Gezgini için URI'yi belirtebilir veya veri alımı uç noktalarını Azure Synapse Veri Gezgini.
   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 Microsoft Entra yönetilen kimlik. 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 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ında Streaming Analytics işi tarafından yönetilen kimlik izinlerinin el ile verilmesi gerekir.

İlgili içerik

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