Клиент командной строки Apache Storm в Python

Question

Я новичок в python и использую шторм (1.0.1) на hdinsight. Когда я искал, все, что я могу видеть, это разработка шторма с использованием Python. Но мне нужна помощь ниже. Можете ли вы, пожалуйста, дайте мне знать, как я могу использовать шторм "клиент командной строки", как 1) список штормов 2) монитор штормов 3) уничтожение штормов с помощью python На данный момент я делаю ssh для подключения hdinsight и выполнения этих команд. Как я могу сделать то же самое в Python и какие функции библиотеки мне нужно импортировать? есть ли блог / документация? Ценю вашу помощь!

Спасибо.

Answer 1

Я не уверен, почему вам нужно вызывать эти команды через Python, но это возможно. Вы можете вызывать те же команды, что и Storm CLI, через Thrift. Хорошей отправной точкой будет рассмотрение команд, реализованных здесь Streamparse https://github.com/Parsely/streamparse/tree/master/streamparse/cli.

Storm CLI также основан на Python (который вызывает классы Java, которые выполняют вызовы Thrift, упомянутые выше). Взгляните на https://github.com/apache/storm/blob/master/bin/storm.py.