flume+kafka+storm+http(分詞)

2512 ワード

一、http+storm
1、ポートテスト
1.1スタートstormサービス
apache-storm-00.93/conf/bin/カタログ下

マスター

  python storm nimbus &
  python storm ui &
  python storm logviewer &

slaave 1、slaave 2

  python storm supervisor &
  python storm logviewer &

1.2簡単テスト
1.2.1 httpポートを起動する

nc -l 8808

1.2.2スタートテストクラス

python /usr/local/src/apache-storm-0.9.3/bin/storm jar \
    /usr/local/src/learn/albert/24_storm_extend/extend.jar \
    stormHttp.HttpClientTest

2、webテスト
2.1起動storm
同じ1.1
2.2 pywebを起動する

python 25_http_storm.py 8808

2.3起動テストクラス

python /usr/local/src/apache-storm-0.9.3/bin/storm jar \
	/usr/local/src/learn/albert/24_storm_extend/extend.jar \
	stormHttp.HttpClientTest

二、flume+kafka+storm+分詞
1.サービスの開始
1.1flume kafka storm
flume+kafka+stormと同じです.
1.2 pyweb(分詞)
pywebのコード——25_http_storm.py

python 25_http_storm.py 8808

2.起動タスク

python /usr/local/src/apache-storm-0.9.3/bin/storm jar \
	/usr/local/src/learn/albert/24_storm_extend/extend.jar \
	stormHttp.StormKafka

kafkaとflum+kafka+stormは展示していません.

添付:もしエラーが発生したら、topicフォーマットが正しくないかもしれません.削除、新規作成すればいいです.
kafka_2.11-0.0.0.1/カタログの下

./bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic storm_kafka

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partition 5 --topic storm_kafka

Android UI開発第六編、QQを模倣したスライドTab

CORS問題まとめ一