質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

91.24%

  • Python 3.x

    2810questions

    Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。

Python Paramiko SSHExceptionエラーの例外処理

解決済

回答 2

投稿 編集

  • 評価
  • クリップ 0
  • VIEW 58

minhouse10

score 12

Pythonオブジェクト指向プログラミングは勉強の段階の身なのですが、以下ParamikoモジュールによるSSH接続と接続先の複数のLinuxサーバー上でコマンド実行し結果を返す処理を行うプログラムを知人の助けを借りて作成しました。(別txtファイルから接続先サーバーIPと実行コマンドを読み込む仕様です)

追加したい機能はSSH接続に失敗した際にエラー例外処理を行い、エラー内容とメッセージを出力後、処理を最後まで継続するように変更する事です。現在はSSH処理が失敗した段階で以降の処理が停止してしまう状態です。

https://www.programcreek.com/python/example/7495/paramiko.SSHException
上記ページを参照し試行錯誤してみてはみますが、オブジェクト指向で書かれた処理にどう綺麗に当該処理を加える事ができるのか今のところ上手くいっておりません。

ご教授の程よろしくお願いいたします。

YouheiSakurai様のご回答によりTimeoutError発生後も停止せずに以下任意のエラー出力と共に処理継続する事が確認できました!

 SSH connection failed for xx.xx.xx.xxx ##

修正後のコード:

#Modules
import paramiko
from contextlib import suppress
from paramiko import SSHException

#Variables
USER = 'UserID'
PSWD = 'password'


#Classes and Functions
class InputReader:
    def __init__(self, commands_path, hosts_path):
        self.commands_path = commands_path
        self.hosts_path = hosts_path

    def read(self):
        self.commands = self.__readlines(self.commands_path)
        self.hosts = self.__readlines(self.hosts_path)

    def __readlines(self, path):
        with open(path) as f:
            # return map(lambda v: v.strip(), f.readlines())
            return [v.strip() for v in f.readlines()] #List comprehension

class CommandExecuter:
    def __init__(self, host, command):
        self.host = host
        self.command = command

    def execute(self):
       with suppress(TimeoutError):
           ssh = paramiko.SSHClient()
           ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
           ssh.connect(self.host, username=USER, password=PSWD)

           stdin, stdout, stderr = ssh.exec_command(self.command)

           errors = stderr.readlines()

           lines = [v.strip() for v in stdout.readlines()]
           return lines
       print('## SSH connection failed for %s ##' % h + '\n')

#Main Procedure
if __name__ == '__main__':
        reader = InputReader("commands2.txt", "systems2.txt")
        reader.read()

        for h in reader.hosts:
                for c in reader.commands:
                        executer = CommandExecuter(h, c)
                        results = executer.execute()
                        print("IP:{0}({1}):".format(h, c) + '\n')
                        if results !=  None:
                                for i in results:
                                        print(i + '\n')

修正前のコード:

import paramiko

#Variables
USER = 'UserID'
PSWD = 'password'

#Classes and Functions
class InputReader:
    def __init__(self, commands_path, hosts_path):
        self.commands_path = commands_path
        self.hosts_path = hosts_path

    def read(self):
        self.commands = self.__readlines(self.commands_path)
        self.hosts = self.__readlines(self.hosts_path)

    def __readlines(self, path):
        with open(path) as f:
            return [v.strip() for v in f.readlines()] #List comprehension

class CommandExecuter:
    def __init__(self, host, command):
        self.host = host
        self.command = command

    def execute(self):
        ssh = paramiko.SSHClient()
        ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        ssh.connect(self.host, username=USER, password=PSWD)

        stdin, stdout, stderr = ssh.exec_command(self.command)

        errors = stderr.readlines()
        '''if len(errors) != 0:
            #raise Exception(errors)'''

        lines = [v.strip() for v in stdout.readlines()]
        #ssh.close()
        return lines

#Main Procedure
if __name__ == '__main__':
    reader = InputReader("commands.txt", "systems.txt")
    reader.read()

    for h in reader.hosts:
        for c in reader.commands:
            executer = CommandExecuter(h, c)
            results = executer.execute()
            print("{0}({1}):".format(h, c))
            if results !=  None:
                for i in results:
                    print(i)
                print('\n')
  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 2

+2

contextlib.suppressを使えば見通しよくエラーを無視できますよ

from contextlib import suppress
from paramiko import SSHException


with suppress(SSHException):
    ...  # SSHに関する処理、例外が発生したらwithブロックを抜ける
print('とりあえずかんry')

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2017/12/16 22:40

    YouheiSakurai様、ご回答頂き本当にありがとうございました!
    早速実装し、たま実行の結果ここにてご報告させて頂きます。

    キャンセル

  • 2017/12/17 00:12 編集

    YouheiSakurai様、頂いたアドバイスに沿って、contextlibにより期待した結果を得る事ができました。ただエラーは適当な存在しないアドレスを使って検証したところ、TimeoutErrorとなったためその点、SSHExceptionではなくTimeoutErrorとする必要がありました。今回おかげ様で素早く解決する事ができました。改めてありがとうございました。

    キャンセル

check解決した方法

0

from contextlib import suppress
from paramiko import SSHException

上記contextlibのsuppressメソッドにより、あるホストに対するSSH接続タイムアウト処理発生時の処理を停止せず、エラーのみを出力するコードに変更できた。
修正後のコード添付済み

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

15分調べてもわからないことは、teratailで質問しよう!

ただいまの回答率

91.24%

関連した質問

  • 受付中

    字下げについて

    お世話になります 本日マイナビ第26章を勉強しております http://news.mynavi.jp/series/python/026/ この中でどうしてもコマンドの字下げ

  • 解決済

    AttributeError: 'Cifar10Reader' object has no attr...

    AttributeError: 'Cifar10Reader' object has no attribute 'bytestream'  のエラー が出ました。 reader.

  • 解決済

    Python メソッド間の変数の呼び出しについて

    Pythonを勉強しておりまして、現在は主にオブジェクト指向の考え方を学んでおります(オブジェクト指向はほとんど初学です)。これまでに書いたシンプルなプログラムをクラスとメソッドで

  • 解決済

    wxPythonにおけるテキストボックスへのテキストの表示

    前提・実現したいこと ドラッグアンドドロップまたはダイアログでファイルを選択した際に、テキストボックスにファイルのアドレスを表示させようとしています。 発生している問題・エ

  • 解決済

    Pythonのループ操作

    Python超初心者です。 以下のような計算を行いたいときにはどのようなコードを書けばいいでしょうか? ある原子の座標があったとして、それらのステップ毎の計算を一気に行いたいで

  • 解決済

    pythonの変数について

    class内で宣言した変数を別のclassで使用したいときgloval以外でどのように書けば良いですか? コードの書き方を教えてください。

  • 解決済

    センサーで感知すると天気予報を喋るプログラムの作り方

    前提・実現したいこと Raspberry piにセンサーを接続させて、天気予報を喋らせるというプログラムを実行したいのですがエラーがでて実行できませんでした。  センサーを接続させ

  • 解決済

    【pyqy5】画像の表示方法を工夫したい

    python3を使っています。pyqt5で下のようなウィジットを作りたいです 黄色いボタンを押すと前後の画像が真ん中に来るようにしたいです。しかし、どうすればいいのかよく分か

同じタグがついた質問を見る

  • Python 3.x

    2810questions

    Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。