Aracılığıyla paylaş

Azure Stream Analytics kullanarak Azure Depolama Blobu'ndan Azure Data Lake Storage 1. Nesil'e veri Stream

  • Makale

Bu makalede, Azure Stream Analytics işi için çıkış olarak Azure Data Lake Storage 1. Nesil'i kullanmayı öğreneceksiniz. Bu makalede, Azure Depolama blobundaki verileri okuyan (giriş) ve verileri Data Lake Storage 1. Nesil (çıkış) dosyasına yazan basit bir senaryo gösterilmektedir.

Önkoşullar

Bu öğreticiye başlamadan önce aşağıdakilere sahip olmanız gerekir:

  • Bir Azure aboneliği. Bkz. Azure ücretsiz deneme sürümü edinme.

  • Azure Depolama hesabı. Stream Analytics işinin verilerini giriş yapmak için bu hesaptan bir blob kapsayıcısı kullanacaksınız. Bu öğreticide storageforasa adlı bir depolama hesabınız ve hesabın içinde storageforasacontainer adlı bir kapsayıcınız olduğunu varsayalım. Kapsayıcıyı oluşturduktan sonra, kapsayıcıya örnek bir veri dosyası yükleyin.

  • bir Data Lake Storage 1. Nesil hesabı. Azure portal kullanarak Azure Data Lake Storage 1. Nesil'i kullanmaya başlama başlığındaki yönergeleri izleyin. myadlsg1 adlı bir Data Lake Storage 1. Nesil hesabınız olduğunu varsayalım.

Stream Analytics İşi oluşturma

Giriş kaynağı ve çıkış hedefi içeren bir Stream Analytics işi oluşturarak başlarsınız. Bu öğretici için kaynak bir Azure blob kapsayıcısı ve hedef Data Lake Storage 1. Nesil.

  1. Azure portal oturum açın.

  2. Sol bölmeden Stream Analytics işleri'ne ve ardından Ekle'ye tıklayın.

    Stream Analytics İşi Oluşturma

    Not

    Depolama hesabıyla aynı bölgede iş oluşturduğunuzdan emin olun, aksi takdirde bölgeler arasında veri taşımanın ek maliyetine neden olursunuz.

İş için Blob girişi oluşturma

  1. Stream Analytics işinin sayfasını açın, sol bölmeden Girişler sekmesine tıklayın ve ardından Ekle'ye tıklayın.

    Girişler seçeneğinin ve Akış girişi ekle seçeneğinin vurgulu olduğu Stream Analytics İşi dikey penceresinin ekran görüntüsü.

  2. Yeni giriş dikey penceresinde aşağıdaki değerleri sağlayın.

    Blob depolama - yeni giriş dikey penceresinin ekran görüntüsü.

    • Giriş diğer adı için iş girişi için benzersiz bir ad girin.

    • Kaynak türü içinVeri akışı'na tıklayın.

    • Kaynak olarak Blob depolama'yı seçin.

    • Abonelik için Geçerli abonelikten blob depolama kullan'ı seçin.

    • Depolama hesabı için önkoşulların bir parçası olarak oluşturduğunuz depolama hesabını seçin.

    • Kapsayıcı için, seçili depolama hesabında oluşturduğunuz kapsayıcıyı seçin.

    • Olay serileştirme biçimi için CSV'yi seçin.

    • Sınırlayıcı için Sekme'yi seçin.

    • Kodlama için UTF-8'i seçin.

      Oluştur’a tıklayın. Portal artık girişi ekler ve bu girişe bağlantıyı test eder.

İş için Data Lake Storage 1. Nesil çıkışı oluşturma

  1. Stream Analytics işinin sayfasını açın, Çıkışlar sekmesine tıklayın, Ekle'ye tıklayın ve Data Lake Storage 1. Nesil seçin.

    Çıkışlar seçeneği, Ekle seçeneği ve 1. Nesil Data Lake Storage seçeneğinin vurgulu olduğu Stream Analytics İşi dikey penceresinin ekran görüntüsü.

  2. Yeni çıkış dikey penceresinde aşağıdaki değerleri sağlayın.

    Yetkile seçeneği vurgulu Data Lake Storage 1. Nesil - yeni çıkış dikey penceresinin ekran görüntüsü.

    • Çıkış diğer adı olarak, iş çıkışı için benzersiz bir ad girin. Bu, sorgu çıkışını bu Data Lake Storage 1. Nesil hesabına yönlendirmek için sorgularda kullanılan kolay bir addır.
    • Data Lake Storage 1. Nesil hesabına erişimi yetkilendirmeniz istenir. Yetki ver'e tıklayın.

  3. Yeni çıkış dikey penceresinde aşağıdaki değerleri sağlamaya devam edin.

    Data Lake Storage 1. Nesil - yeni çıkış dikey penceresinin ekran görüntüsü.

    • Hesap adı için, iş çıkışının gönderilmesini istediğiniz önceden oluşturduğunuz Data Lake Storage 1. Nesil hesabı seçin.

    • Yol ön eki düzeni için, belirtilen Data Lake Storage 1. Nesil hesabı içinde dosyalarınızı yazmak için kullanılan bir dosya yolu girin.

    • Tarih biçimi için, ön ek yolunda bir tarih belirteci kullandıysanız, dosyalarınızın düzenlendiği tarih biçimini seçebilirsiniz.

    • Zaman biçimi için, ön ek yolunda bir zaman belirteci kullandıysanız, dosyalarınızın düzenlendiği saat biçimini belirtin.

    • Olay serileştirme biçimi için CSV'yi seçin.

    • Sınırlayıcı için Sekme'yi seçin.

    • Kodlama için UTF-8'i seçin.

      Oluştur’a tıklayın. Portal artık çıkışı ekler ve bu çıkışla bağlantıyı test eder.

Stream Analytics işini çalıştırma

  1. Stream Analytics işini çalıştırmak için Sorgu sekmesinden bir sorgu çalıştırmanız gerekir. Bu öğreticide, aşağıdaki ekran görüntüsünde gösterildiği gibi yer tutucuları iş girişi ve çıkış diğer adlarıyla değiştirerek örnek sorguyu çalıştırabilirsiniz.

    Sorgu çalıştırma Sorguyu

  2. Ekranın üst kısmından Kaydet'e tıklayın ve genel bakış sekmesinde Başlat'a tıklayın. İletişim kutusunda Özel Saat'i seçin ve geçerli tarih ve saati ayarlayın.

    İş zamanını ayarlama İş

    İşi başlatmak için Başlat'a tıklayın. İşin başlatılması birkaç dakika kadar sürebilir.

  3. Blobdan veri seçme işini tetikleme amacıyla örnek bir veri dosyasını blob kapsayıcısına kopyalayın. Azure Data Lake Git Deposundan örnek bir veri dosyası alabilirsiniz. Bu öğretici için dosyasını vehicle1_09142014.csvkopyalayalım. Blob kapsayıcısına veri yüklemek için Azure Depolama Gezgini gibi çeşitli istemcileri kullanabilirsiniz.

  4. Genel Bakış sekmesindeki İzleme'nin altında verilerin nasıl işlendiğine bakın.

    İşi izleme

  5. Son olarak, iş çıktı verilerinin Data Lake Storage 1. Nesil hesabında kullanılabilir olduğunu doğrulayabilirsiniz.

    Çıkışı doğrulama

    Veri Gezgini bölmesinde, çıkışın Data Lake Storage 1. Nesil çıktı ayarlarında (streamanalytics/job/output/{date}/{time} ) belirtildiği gibi bir klasör yoluna yazıldığını görebilirsiniz.

Ayrıca bkz.