Hızlı başlangıç: Azure HDInsight 'ta Apache Storm topolojisi oluşturma ve izlemeQuickstart: Create and monitor an Apache Storm topology in Azure HDInsight

Apache Storm, veri akışlarını işlemeye yönelik ölçeklenebilir, hataya dayanıklı, dağıtılmış ve gerçek zamanlı bir işlem sistemidir.Apache Storm is a scalable, fault-tolerant, distributed, real-time computation system for processing streams of data. Azure HDInsight’ta Storm ile büyük veri analizini gerçek zamanlı olarak gerçekleştiren bulut tabanlı bir Storm kümesi oluşturabilirsiniz.With Storm on Azure HDInsight, you can create a cloud-based Storm cluster that performs big data analytics in real time.

Bu hızlı başlangıçta, var olan bir Apache Storm kümesine Apache Storm topolojisi oluşturmak ve izlemek için Apache fırtınası-başlangıç projesinden bir örnek kullanırsınız.In this quickstart, you use an example from the Apache storm-starter project to create and monitor an Apache Storm topology to an existing Apache Storm cluster.

ÖnkoşullarPrerequisites

Topolojiyi oluşturmaCreate the topology

  1. Fırtınası kümenize bağlanın.Connect to your Storm cluster. CLUSTERNAME, fırtınası kümenizin adıyla değiştirerek aşağıdaki komutu düzenleyin ve ardından şu komutu girin:Edit the command below by replacing CLUSTERNAME with the name of your Storm cluster, and then enter the command:

    ssh sshuser@CLUSTERNAME-ssh.azurehdinsight.net
    
  2. WORDCOUNT örneği /usr/hdp/current/storm-client/contrib/storm-starter/HDInsight kümenize eklenmiştir.The WordCount example is included on your HDInsight cluster at /usr/hdp/current/storm-client/contrib/storm-starter/. Topoloji rastgele cümleler oluşturur ve sözcüklerin kaç kez meydana geçtiğini sayar.The topology generates random sentences and counts how many times words occur. Kümede WORDCOUNT topolojisini başlatmak için aşağıdaki komutu kullanın:Use the following command to start the wordcount topology on the cluster:

    storm jar /usr/hdp/current/storm-client/contrib/storm-starter/storm-starter-topologies-*.jar org.apache.storm.starter.WordCountTopology wordcount
    

Topolojiyi izlemeMonitor the topology

Fırtınası, çalışan topolojilerle çalışmaya yönelik bir Web arabirimi sağlar ve HDInsight kümenize dahildir.Storm provides a web interface for working with running topologies, and is included on your HDInsight cluster.

Storm Kullanıcı Arabirimini kullanarak topolojiyi izlemek için aşağıdaki adımları kullanın:Use the following steps to monitor the topology using the Storm UI:

  1. Storm kullanıcı arabirimini görüntülemek için bir web tarayıcısı açarak https://CLUSTERNAME.azurehdinsight.net/stormui adresine gidin.To display the Storm UI, open a web browser to https://CLUSTERNAME.azurehdinsight.net/stormui. CLUSTERNAME değerini kümenizin adıyla değiştirin.Replace CLUSTERNAME with the name of your cluster.

  2. Topoloji Özetialtında ad sütununda WORDCOUNT girişini seçin.Under Topology Summary, select the wordcount entry in the Name column. Topoloji hakkında bilgiler görüntülenir.Information about the topology is displayed.

    Storm-starter WordCount topoloji bilgilerini içeren Storm Panosu.

    Yeni sayfa aşağıdaki bilgileri sağlar:The new page provides the following information:

    ÖzellikProperty AçıklamaDescription
    Topoloji istatistikleriTopology stats Topoloji performansı hakkında zaman pencereleri halinde düzenlenmiş temel bilgiler.Basic information on the topology performance, organized into time windows. Belirli bir zaman penceresinin seçilmesi sayfanın diğer bölümlerinde gösterilen bilgiler için zaman penceresini değiştirir.Selecting a specific time window changes the time window for information displayed in other sections of the page.
    SpoutSpouts Her Spout tarafından döndürülen son hata dahil olmak üzere spomalar hakkındaki temel bilgiler.Basic information about spouts, including the last error returned by each spout.
    CıvatalarBolts Cıvatları hakkında temel bilgiler.Basic information about bolts.
    Topoloji yapılandırmasıTopology configuration Topoloji yapılandırması hakkında ayrıntılı bilgi.Detailed information about the topology configuration.
    EtkinleştirActivate Devre dışı bırakılan bir topoloji işlemeyi sürdürür.Resumes processing of a deactivated topology.
    ÇıkarmaDeactivate Çalışan bir topolojiyi duraklatır.Pauses a running topology.
    DengelemeRebalance Topolojinin paralelliğini ayarlar.Adjusts the parallelism of the topology. Kümedeki düğüm sayısını değiştirdikten sonra çalışan topolojileri yeniden dengelemeniz gerekir.You should rebalance running topologies after you have changed the number of nodes in the cluster. Yeniden dengeleme, kümede artan/azalan düğüm sayısını dengelemek üzere paralelliği ayarlamaya imkan tanır.Rebalancing adjusts parallelism to compensate for the increased/decreased number of nodes in the cluster. Daha fazla bilgi için bkz. Apache Storm topolojisinin paralelliğini anlama.For more information, see Understanding the parallelism of an Apache Storm topology.
    KapatmayınKill Belirtilen zaman aşımından sonra bir fırtınası topolojisini sonlandırır.Terminates a Storm topology after the specified timeout.
  3. Bu sayfada Spout’lar veya Cıvatalar bölümünden bir giriş seçin.From this page, select an entry from the Spouts or Bolts section. Seçilen bileşen hakkında bilgiler görüntülenir.Information about the selected component is displayed.

    Seçili bileşenler hakkında bilgi içeren Storm Panosu.

    Yeni sayfa aşağıdaki bilgileri görüntüler:The new page displays the following information:

    ÖzellikProperty AçıklamaDescription
    Spout/cıvata istatistikleriSpout/Bolt stats Zaman pencereleri halinde düzenlenmiş bileşen performansı hakkındaki temel bilgiler.Basic information on the component performance, organized into time windows. Belirli bir zaman penceresinin seçilmesi sayfanın diğer bölümlerinde gösterilen bilgiler için zaman penceresini değiştirir.Selecting a specific time window changes the time window for information displayed in other sections of the page.
    Giriş İstatistikleri (yalnızca cıvatlar)Input stats (bolt only) Cıvata tüketilen verileri üreten bileşenler hakkında bilgi.Information on components that produce data consumed by the bolt.
    Çıkış istatistikleriOutput stats Bu cıvata yayılan verilerle ilgili bilgiler.Information on data emitted by this bolt.
    YürütücülerExecutors Bu bileşenin örnekleri hakkında bilgi.Information on instances of this component.
    HatalarErrors Bu bileşen tarafından oluşturulan hatalar.Errors produced by this component.
  4. Spout veya cıvata ayrıntılarını görüntülerken bileşenin belirli bir örneğine ilişkin ayrıntıları görmek için Yürütücüler bölümündeki Bağlantı Noktası sütunundan bir giriş seçin.When viewing the details of a spout or bolt, select an entry from the Port column in the Executors section to view details for a specific instance of the component.

     2015-01-27 14:18:02 b.s.d.task [INFO] Emitting: split default ["with"]
     2015-01-27 14:18:02 b.s.d.task [INFO] Emitting: split default ["nature"]
     2015-01-27 14:18:02 b.s.d.executor [INFO] Processing received message source: split:21, stream: default, id: {}, [snow]
     2015-01-27 14:18:02 b.s.d.task [INFO] Emitting: count default [snow, 747293]
     2015-01-27 14:18:02 b.s.d.executor [INFO] Processing received message source: split:21, stream: default, id: {}, [white]
     2015-01-27 14:18:02 b.s.d.task [INFO] Emitting: count default [white, 747293]
     2015-01-27 14:18:02 b.s.d.executor [INFO] Processing received message source: split:21, stream: default, id: {}, [seven]
     2015-01-27 14:18:02 b.s.d.task [INFO] Emitting: count default [seven, 1493957]
    

    Bu örnekte seven kelimesi 1493957 kez geçmiştir.In this example, the word seven has occurred 1493957 times. Bu sayı, bu topoloji başlatıldığından beri kelimeyle kaç kez karşılaşıldığını gösterir.This count is how many times the word has been encountered since this topology was started.

Topolojiyi durdurmaStop the topology

Word-count topolojisi için Topoloji özeti sayfasına geri dönün ve ardından Topoloji eylemleri bölümünden Sonlandır düğmesini seçin.Return to the Topology summary page for the word-count topology, and then select the Kill button from the Topology actions section. İstendiğinde, topolojiyi durdurmadan önce beklenecek saniye sayısı için 10 girin.When prompted, enter 10 for the seconds to wait before stopping the topology. Zaman aşımı süresinden sonra panonun Storm Kullanıcı Arabirimi bölümünü ziyaret ettiğinizde topoloji bir daha görünmez.After the timeout period, the topology no longer appears when you visit the Storm UI section of the dashboard.

Kaynakları temizlemeClean up resources

Hızlı başlangıcı tamamladıktan sonra kümeyi silmek isteyebilirsiniz.After you complete the quickstart, you may want to delete the cluster. HDInsight ile, verileriniz Azure Storage’da depolanır, böylece kullanılmadığında bir kümeyi güvenle silebilirsiniz.With HDInsight, your data is stored in Azure Storage, so you can safely delete a cluster when it is not in use. Ayrıca, kullanılmıyorken dahi HDInsight kümesi için sizden ücret kesilir.You are also charged for an HDInsight cluster, even when it is not in use. Küme ücretleri depolama ücretlerinin birkaç katı olduğundan, kullanılmadığında kümelerin silinmesi mantıklı olandır.Since the charges for the cluster are many times more than the charges for storage, it makes economic sense to delete clusters when they are not in use.

Bir kümeyi silmek için bkz. tarayıcınızı, PowerShell 'i veya Azure CLI 'yı kullanarak HDInsight kümesini silme.To delete a cluster, see Delete an HDInsight cluster using your browser, PowerShell, or the Azure CLI.

Sonraki adımlarNext steps

Bu hızlı başlangıçta, var olan bir Apache Storm kümesine Apache Storm topolojisi oluşturmak ve izlemek için Apache fırtınası-başlangıç projesinden bir örnek kullandınız.In this quickstart, you used an example from the Apache storm-starter project to create and monitor an Apache Storm topology to an existing Apache Storm cluster. Apache Storm topolojileri yönetme ve izleme hakkında temel bilgileri öğrenmek için sonraki makaleye ilerleyin.Advance to the next article to learn the basics of managing and monitoring Apache Storm topologies.