ローカルのpythonのparamikoを使用して、AWSのec2へSSH接続してログファイルを取得したい

Question

前提・実現したいこと

ローカルのpython環境から、AWSのec2へ接続して、踏み台サーバから、
APサーバへ接続し、ログファイルを取得するプログラムを作成しています。

pythonからLinuxコマンドが使用できるライブラリ：paramikoを使用して、
以下のLinuxコマンドを実行して、ログファイルを取得しようと考えております。

■処理フロー
0. 踏み台サーバへSSH接続

1. ssh -i .ssh/XXXXX.pem APサーバのIPアドレス　を実行し、APサーバへ接続
2. sudo su -
3. cd /var/log/tomcat/v1
4. cat XXX.log
5. pythonで4.の結果を受け取る

該当のソースコード

import paramiko

def get_log_file():
  """
  APサーバへ接続し、ログファイルを取得する
  取得した情報はstring型で返却する
  """
  #接続
  ssh = paramiko.SSHClient()
  ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  ssh.connect(踏み台サーバのIPアドレス, ぽーと番号, 接続ユーザ, key_filename=秘密鍵へのファイルパス)

  #cmdの実行
  stdin, stdout, stderr = ssh.exec_command('ssh -i .ssh/XXXXX.pem APサーバのIPアドレス\n')  # ★★★ここで処理が止まっている？★★★
  for output in stdout:
    print(output.strip())

if __name__ == '__main__':
  get_log_file()

発生している問題・エラーメッセージ

「ssh -i .ssh/XXXXX.pem APサーバのIPアドレス」を実行するとサーバから応答が返ってきておりません。
そこで、「ls -al」を実行してみたところ、サーバから応答があり、
stdoutに「ls -al」の実行結果が格納されてきました。

なんとかAPサーバへ接続して、ログファイルを取得できないでしょうか。

Answer 1

こちらのコードで実現できました。

import paramiko

def get_log_file():
    # SSH接続
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect(接続先IPアドレス, 接続ポート番号, 接続ユーザ名, key_filename=秘密鍵のパス)
    shell = ssh.invoke_shell()

    # sudo su -コマンドの実行し、不要なoutputを吐き出させる
    shell.send('sudo su -\n')
    output = ''
    while not output.endswith('~]# '): # 末尾が'~]# 'まで読み取る
        output = shell.recv(100).decode('utf-8')  # 100byte読み込み

    # cd /var/log/tomcat/v1コマンドの実行し、不要なoutputを吐き出させる
    shell.send('cd /var/log/tomcat/v1\n')
    output = ''
    while not output.endswith('v1]# '): # 末尾が'v1]# 'まで読み取る
        output = shell.recv(100).decode('utf-8')  # 100byte読み込み

    # fgrepコマンドの実行し、ログの内容を取得する
    shell.send('fgrep -w "' + os.environ['GREP_STRING'] + '" vgw.log\n')
    log_data_buff = ''
    output = ''
    while not output.endswith(']# '): # 末尾が']# 'まで読み取る
        output = shell.recv(9999).decode(
            'utf-8', errors='ignore')  # 9999byte読み込み(UTF-8に変換できない文字は読み飛ばす)
        log_data_buff += output

    # SSH接続切断
    ssh.close()

    # コマンドを削除しつつ、リスト化
    delete_target_index = log_data_buff.find('\n')
    log_data = log_data_buff[delete_target_index + 1:].split('\r\n')

    return log_data

if __name__ == '__main__':
    get_log_file()

Answer 2

stdin, stdout, stderr = ssh.exec_command('ssh -i .ssh/XXXXX.pem APサーバのIPアドレス\n')
のところでは単にAPサーバにSSHログインしているだけに見えるのですが、実際にこのコードを使っていますでしょうか。
tomcatのログをcatする処理が書かれていないように思えます。（ログ取得とありますが、ローカルからtomcatのログを標準出力したい、ということでよろしいですか？）
このコードであればAPサーバにSSHログインするところで入力待ちになっていると思われますので正しい挙動かと思います（手元で確認してるわけではないので誤っていたら申し訳ないです）。

Comments

[KoshiroNomura]

>> stdin, stdout, stderr = ssh.exec_command('ssh -i .ssh/XXXXX.pem APサーバのIPアドレス\n')
>>のところでは単にAPサーバにSSHログインしているだけに見えるのですが、実際にこのコードを使っていますでしょうか。
★stdin, stdout, stderr = ssh.exec_command('ssh -i .ssh/XXXXX.pem APサーバのIPアドレス\n') の箇所で止まっているため、
　そこまでしか記述しておりませんでした。

>>tomcatのログをcatする処理が書かれていないように思えます。（ログ取得とありますが、ローカルからtomcatのログを標準出力したい、ということでよろしいですか？）
★はい、その通りです。

完成形は処理フローは

1.踏み台サーバへSSH接続
2.ssh -i .ssh/XXXXX.pem APサーバのIPアドレス　を実行し、APサーバへ接続
3.sudo su -
4.cd /var/log/tomcat/v1
5.cat XXX.log
6.pythonで4.の結果を受け取る

なのですが、現状、1.踏み台サーバへSSH接続　下記のご指摘の通りですが、処理が止まっているため、
後続の処理の記述はしておりませんでした。

>>このコードであればAPサーバにSSHログインするところで入力待ちになっていると思われますので正しい挙動かと思います（手元で確認してるわけではないので誤っていたら申し訳ないです）。
★入力待ちになっているとのご指摘ありがとうございます。
　大変申し訳ないのですが、どのような入力を行えば処理が進むのかご存じでしたら
　ご教授いただけますでしょうか。

[yu_1985]

`ssh -i .ssh/XXXXX.pem APサーバのIPアドレス `の後に`"実行したいコマンド"`（ここで言うと `cat /var/log/tomcat/v1/xxx.log`）を入力するとリモートでコマンド実行してくれるので、コマンドをそのように修正すればよいかと思います。
SSH先でsudoが必要な場合はsshに-tオプションが必要です
参考までに以前自分がQiitaに書いたものを
https://qiita.com/yutaro1985/items/e01586c263fb16fec9ba