Клиент командной строки Apache Storm на Python
Я новичок в python и использую storm (1.0.1) на hdinsight. Когда я искал, все, что я видел, - это развитие шторма с использованием python. Но мне нужна помощь, указанная ниже. не могли бы вы сообщить мне, как я могу использовать Storm "клиент командной строки", например 1) список штормов 2) монитор штормов 3) уничтожение шторма с использованием Python На данный момент я использую ssh для подключения hdinsight и выполнения этих команд. как я могу сделать то же самое в python и какие библиотечные функции мне нужно импортировать? есть ли блог / документация. Ценю вашу помощь!
Спасибо.
Ответы 1
Я не уверен, почему вам нужно вызывать эти команды через Python, но это возможно. Вы можете вызывать те же команды, что и Storm CLI, через Thrift. Хорошей отправной точкой будет рассмотрение команд, реализованных Streamparse здесь https://github.com/Parsely/streamparse/tree/master/streamparse/cli.
Интерфейс командной строки Storm также основан на Python (который вызывает классы Java, которые выполняют упомянутые выше вызовы Thrift). Взгляните на https://github.com/apache/storm/blob/master/bin/storm.py.