python玩storm趟坑记

准备开始学习storm。storm是最有名的实时流处理,spark虽然也有spark streaming,出来得比较晚,要趟的坑比storm要多,首选还是storm。

storm是核心是Clojure编写的,号称可以支持任何一种语言来编写拓扑。

由于只会玩python,所以还是得从python中选择对应的库文件。

Python目前有两个库,一个是pyleus,一个是streamparse。前者在github上已经有两年都不更新了,只支持到storm 0.9。后者一直在更新,所以对于最新的strom 1.1.0, 没有多的选项了。

storm本地伪集群我采用了官网配置

storm.zookeeper.servers:
     - "127.0.0.1"

nimbus.seeds: ["127.0.0.1"]
ui.port: 9090

nimbus.host: "localhost"
supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
    - 6703

由于ui默认的8080端口被我用来搞polipo了,这里设置网页端口为9090.

然后按如下顺序启动storm即可:

cd /xxx/yyy/apache-storm-1.1.0/bin
./storm nimbus &
./storm supervisor &
./storm ui &

打开localhost:9090,如果没啥问题,就能看到storm的管理页面。

然后开始安装streamparse,因为我使用了虚拟环境,所以无需sudo:

pip install streamparse

然后开始跑demo:

sparse quickstart wordcount
cd wordcount
sparse run

结果直接跳错,告诉我缺少lein,搞得我一脸懵逼。google了一下,才知道这是Clojure的包管理工具。于是直接去lein官网

lein的安装有两种方式,一种是用脚本下载安装,一种是要加PPA。原本lein也提供apt直接的安装了,结果各种历史原因,所以呵呵了。。。

作为懒人,首选脚本下载。结果速度奇慢无比。。。看着安装进度需要一天,我果断放弃。。。

只能选择PPA添加apt安装了:

sudo add-apt-repository ppa:mikegedelman/leiningen-git-stable
sudo apt-get update
sudo apt-get install lein

完成后继续跑sparse run命令。。结果还是不行,去stackoverflow翻了一通后发现,需要配置config.json。但是streamparse的demo里没提,说创建完项目直接就能跑,我顿时感觉有点坑啊。。。

配置config.json如下:

{
    "serializer": "json",
    "topology_specs": "topologies/",
    "virtualenv_specs": "virtualenvs/",
    "envs": {
        "prod": {
            "user": "user_xxx",
            "ssh_password": "password",
            "nimbus": "localhost",
            "workers": ["localhost"],
            "log": {
                "path": "",
                "max_bytes": 1000000,
                "backup_count": 10,
                "level": "info"
            },
            "virtualenv_root": "/path_xx/virtualenvs"
        }
    }
}

然后试着运行:

sparse run

然后立刻被打脸,说ssh user_xxx@localhost要输入密码,如果sshd_config如果没配置,即便输入正确的密码也会失败。这里可以参考我之前写的如何ssh本地主机

配置完免密码登录后,连密码一栏都不用搞了,再次运行。

机器会花一定时间来编译JAR文件,然后就能看到实时流的输出了。

但是这只是试运行,如果要发布拓扑到storm集群上,则要运行:

sparse submit

结果又跳了一个错,说pip版本太低。。。

streamparse会在节点上构建python的虚拟环境, 然后在节点上安装好所有需要的python库。看脚本执行的顺序,会在生成虚拟环境后自动升级pip。但是不知道为何没有执行成功。所以我只能手动去对应的路径里升级pip:

cd /path_xx/virtualenvs/wordcount/bin
source activate
pip install --upgrade pip
deactivate

最后再次运行:

sparse submit

没有报错就表示已经提交拓扑到storm上了,打开ui地址,可以看到拓扑一栏里已经显示有wordcount的拓扑在运行。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,723评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,080评论 2 379
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,604评论 0 335
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,440评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,431评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,499评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,893评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,541评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,751评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,547评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,619评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,320评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,890评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,896评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,137评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,796评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,335评论 2 342

推荐阅读更多精彩内容