我是python新手，在hdinsight上使用storm（1.0.1）。当我搜索时，我看到的只是使用python开发storm。但我需要下面的帮助。请告诉我如何使用storm“command line client”，如1）storm list 2）storm monitor 3）storm kill使用python截至目前，我使用ssh连接hdinsight并执行这些命令。如何在python中实现同样的功能？需要导入哪些库函数？有博客/文档吗。谢谢你的帮助！
谢谢。
我是python新手，在hdinsight上使用storm（1.0.1）。当我搜索时，我看到的只是使用python开发storm。但我需要下面的帮助。请告诉我如何使用storm“command line client”，如1）storm list 2）storm monitor 3）storm kill使用python截至目前，我使用ssh连接hdinsight并执行这些命令。如何在python中实现同样的功能？需要导入哪些库函数？有博客/文档吗。谢谢你的帮助！
谢谢。
1条答案
按热度按时间bvjveswy1#
我不知道为什么需要通过python调用这些命令，但这是可能的。您可以通过thrift调用与storm cli相同的命令。一个好的起点应该是查看streamparse在这里实现的命令https://github.com/parsely/streamparse/tree/master/streamparse/cli.
stormcli也是基于python的（python调用java类，java类执行上面提到的thrift调用）。看一看https://github.com/apache/storm/blob/master/bin/storm.py.