Event Grid bildirimlerine abone olarak Azure Veri Gezgini blob alma

Azure Veri Gezgini, günlük ve telemetri verileri için hızlı ve üst düzeyde ölçeklenebilir veri keşfetme hizmetidir. Azure Veri Gezgini, Event Hubs, IoT Hub 'larından ve BLOB kapsayıcılarına yazılan bloblardan alma (veri yükleme) sağlar.

Bu makalede, Event Grid veri bağlantısı kullanarak depolama hesabınızdan blob 'ları Azure Veri Gezgini 'a nasıl alabileceğinizi öğreneceksiniz. Bir Azure Event Grid aboneliğini ayarlayan Event Grid veri bağlantısı oluşturacaksınız. Event Grid aboneliği, Azure Olay Hub 'ı aracılığıyla depolama hesabınızdan olayları Azure Veri Gezgini 'a yönlendirir. Daha sonra, sistem genelinde veri akışına bir örnek görürsünüz.

Event Grid Azure Veri Gezgini 'a geri ödeme hakkında genel bilgi için bkz. Bağlan Event Grid. Azure portal el ile kaynak oluşturmak için, bkz. Event Grid alımı Için el ile kaynak oluşturma.

Önkoşullar

• Azure aboneliği. Ücretsiz bir Azure hesabıoluşturun.
• Bir küme ve veritabanıoluşturun.
• Depolama hesabıoluşturun.
• Event Grid bildirim aboneliği BlobStorage ,, StorageV2 veya BlobStorageiçin Azure Depolama hesaplarında ayarlanabilir.

Azure Veri Gezgini'nde hedef tablo oluşturma

Azure Veri Gezgini, Event Hubs veri göndereceği bir tablo oluşturun. Kümede ve ön koşullarda hazırlanan veritabanında tablo oluşturun.

1. Azure portalda kümenizin altında Sorgu'yu seçin.

   

2. Aşağıdaki komutu pencereye kopyalayın ve alınan verileri alacak tabloyu (TestTable) oluşturmak için Çalıştır ' ı seçin.

   .create table TestTable (TimeStamp: datetime, Value: string, Source:string)
   

   

3. Aşağıdaki komutu pencereye kopyalayın ve gelen JSON verilerini tablonun sütun adlarıyla ve veri türleriyle (TestTable) eşlemek için Çalıştır ' ı seçin.

   .create table TestTable ingestion json mapping 'TestMapping' '[{"column":"TimeStamp","path":"$.TimeStamp"},{"column":"Value","path":"$.Value"},{"column":"Source","path":"$.Source"}]'
   

Event Grid veri bağlantısı oluşturma

Depolama hesabını şimdi Azure Veri Gezgini bağlayın, böylece depolama alanına akan verilerin test tablosuna akışı yapılır. Bu bağlantı, depolama hesabının kendisi altında veya Azure Veri Gezgini altındaki Azure portal Azure portal oluşturulabilir.

Dağıtım

Dağıtım tamamlanana kadar bekleyin. Dağıtımınız başarısız olduysa hata nedeni hakkında daha fazla bilgi edinmek için başarısız olan aşamanın yanındaki işlem ayrıntıları ' nı seçin. Kaynakları yeniden dağıtmayı denemek için yeniden Dağıt ' ı seçin. Dağıtımdan önce parametreleri değiştirebilirsiniz.

Örnek veri oluşturma

Artık Azure Veri Gezgini ve depolama hesabı bağlı olduğundan, örnek veri oluşturabilirsiniz.

depolama kapsayıcısına blob Upload

azure Depolama kaynaklarıyla etkileşimde bulunmak için birkaç temel azure clı komutu veren küçük bir kabuk betiği ile çalışacağız. Bu betik aşağıdaki eylemleri yapar:

1. Depolama hesabınızda yeni bir kapsayıcı oluşturur.
2. Var olan bir dosyayı (blob olarak) bu kapsayıcıya yükler.
3. Kapsayıcıdaki Blobları listeler.

Betiği doğrudan portalda yürütmek için Azure Cloud Shell kullanabilirsiniz.

Verileri bir dosyaya kaydedin ve bu komut dosyasıyla karşıya yükleyin:

{"TimeStamp": "1987-11-16 12:00","Value": "Hello World","Source": "TestSource"}

#!/bin/bash
### A simple Azure Storage example script

    export AZURE_STORAGE_ACCOUNT=<storage_account_name>
    export AZURE_STORAGE_KEY=<storage_account_key>

    export container_name=<container_name>
    export blob_name=<blob_name>
    export file_to_upload=<file_to_upload>
    export destination_file=<destination_file>

    echo "Creating the container..."
    az storage container create --name $container_name

    echo "Uploading the file..."
    az storage blob upload --container-name $container_name --file $file_to_upload --name $blob_name --metadata "rawSizeBytes=1024"

    echo "Listing the blobs..."
    az storage blob list --container-name $container_name --output table

    echo "Done"

Blobu yeniden adlandır

Verileri ADLSv2 Storage 'dan içe aktarıyorsanız ve veri bağlantısı için olay türü olarak yeniden adlandırılmış blobu belirlediyseniz, blob alma tetikleyicisi blob yeniden adlandırmasıdır. Bir blobu yeniden adlandırmak için Azure portal blob 'a gidin, bloba sağ tıklayıp Yeniden Adlandır' ı seçin:

Alma özellikleri

Blob meta verileri aracılığıyla blob alma alma özelliklerini belirtebilirsiniz.

Veri akışını inceleme

1. Olay Azure portal altında uygulama çalışırken etkinlik artışını görüyorsunuz.

   

2. Veritabanına ulaşan ileti sayısını denetlemek için test veritabanınızda aşağıdaki sorguyu çalıştırın.

   TestTable
   | count
   

3. İletilerin içeriğini görmek için test veritabanınıza aşağıdaki sorguyu çalıştırın.

   TestTable
   

   Sonuç kümesi aşağıdaki görüntüye benzin:

   

Kaynakları temizleme

Olay kılavuzlarınızı yeniden kullanmayı planlasanız, ücret ödememek için sizin için otomatik olarak Event Grid aboneliğini, Olay Hub'ı ad alanını ve Olay Hub'ını temizleyin.

1. Bu Azure portal, sol menüye gidin ve Tüm kaynaklar'ı seçin.

   

2. Olay Hub'ı Ad Alanınızı arayın ve Sil'i seçerek silin:

   

3. Kaynakları sil formunda, Olay Hub'ı Ad Alanı ve Olay Hub'ı kaynaklarını silmek için silme işlemini onaylayın.

4. Depolama hesabınıza gidin. Sol menüden Olaylar'ı seçin:

   

5. Grafiğin altında, Aboneliğinizi seçin Event Grid sil'i seçin ve sil'i seçin:

   

6. Veri bağlantınızı Event Grid için kümenize Azure Veri Gezgini gidin. Sol menüden Veritabanları'ı seçin.

7. TestDatabase veritabanınızı seçin:

   

8. Sol menüde Veri alımı'ı seçin:

   

9. Test-grid-connection veri bağlantınızı seçin vesil'i seçin.

Sonraki adımlar

• Veri sorgulama Azure Veri Gezgini