2017-05-26 4 views

Antwort

0

Java installieren

herunterladen und installieren Sie ein JDK (Sturm arbeitet mit Oracle und OpenJDK 6/7). Für dieses Setup habe ich JDK 7 von Oracle verwendet.

Ich installierte Java in: C: \ Java \ jdk1.7.0_45 \ Python installieren

Um die Installation zu testen, werden wir das „Wort zählen“ Probe aus dem Sturm-Starter-Projekt werden die Bereitstellung der verwendet eine in Python geschriebene Multi-Lang-Schraube. Ich habe Python 2.7.6 benutzt, welches hier heruntergeladen werden kann.

Ich installierte Python in:

C: \ Python27 \ Installieren und

Run Zookeeper

Herunterladen Apache Zookeeper 3.3.6 und es extrahieren. Konfigurieren und Ausführen von Zookeeper mit den folgenden Befehlen:.

cd zookeeper-3.3.6 Kopie conf \ zoo_sample.cfg conf \ zoo.cfg \ bin \ zkServer.cmd Installieren Sturm

Die Änderungen, die es Storm ermöglichen, unter Windows nahtlos zu laufen, wurden noch nicht offiziell veröffentlicht, aber Sie können einen Build mit diesen Änderungen herunterladen.

(Quellzweig für diesen Build kann hier gefunden werden).

Extrahieren Sie diese Datei an den Speicherort Ihrer Wahl. Ich habe C gewählt.

Konfigurieren von Umgebungsvariablen

Unter Windows Sturm erfordert das STORM_HOME und JAVA_HOME Umgebungsvariablen als auch auf die PATH-Variablen wie einige Ergänzungen gesetzt werden:

JAVA_HOME

C: \ Java \ jdk1 .7.0_45 \ STORM_HOME

C: \ Sturm-0.9.1-Inkubations-snapshot-12.182.013 \ PATH hinzufügen:

% STORM_HOME% \ bin;% JAVA_HOME% \ bin; C: \ Python27; C: \ Python27 \ Lib \ Site-Pakete \; C: \ Python27 \ Scripts \; PATHEXT Anzahl:

Py starten Nimbus, Supervisor und Sturm UI Daemons

Für jeden deamon, öffnen eine separate Eingabeaufforderung.

Nimbus

cd% STORM_HOME% Sturm nimbus Supervisor-

cd% STORM_HOME% Sturm Supervisor Sturm UI

cd% STORM_HOME% Sturm ui Überprüfen, dass Storm läuft durch Öffnen von http://localhost:8080/ in einem Browser.

Stellen Sie die „Word Count“ Topologie

entweder den Sturm-Starter-Projekt von der Quelle bauen, oder laden Sie eine vorgefertigte jar

Stellen Sie die Word-Topologie auf Ihrem lokalen Cluster mit dem Sturm Graf jar Befehl:

Sturm jar Sturm-starter-0.0.1-snapshot-jar-with-dependencies.jar storm.starter.WordCountTopology Wordcount = -c nimbus.host localhost

Verwandte Themen