channel.recv在命令完成后仍未返回提示。’while True’循环未中断。

huangapple
go评论98阅读模式
英文:

channel.recv didn't return prompt back even after command is completed. 'while True' loop didn't break

问题

  1. channel.recv在命令完成后仍未返回提示符。'while True'循环未中断。
  3. 我正在使用paramiko登录一个服务器，用户为'xyz'，然后使用paramiko通道执行'su -'。
  5. ```python
  6. ssh = paramiko.SSHClient()
  7. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  8. try:
  9.     ssh.connect(hostname, username='xyz', password=list_pass(hostname, 'xyz'))
  11.     command = 'puppet agent -t --no-use_cached_catalog ; echo COMMAND_COMPLETED'
  13.     channel = ssh.invoke_shell()
  14.     channel.send("su -\n")
  15.     time.sleep(2)
  16.     channel.send(list_pass(hostname, 'root') + "\n")
  17.     time.sleep(2)
  18.     channel.send(command + '\n')
  19.     time.sleep(5)
  21.     while True:
  22.         if channel.recv:
  23.             time.sleep(1)
  24.             print(channel.recv(1024).decode())
  25.             if "COMMAND_COMPLETED" in channel.recv(1024).decode():
  26.                 break
  27.         else:
  28.             continue
  30.     channel.close()
  31.     ssh.close()
  33. except paramiko.AuthenticationException:
  34.     print("Authentication failed")
  35. except socket.gaierror:
  36.     print(f"无法连接到{hostname}。请验证服务器是否存在且处于运行状态。")

此代码陷入了无限循环。命令仍在运行中。

  2. [在这里输入图像描述](https://i.stack.imgur.com/SZUMI.png)
英文:

channel.recv didn't return prompt back even after command is completed. 'while True' loop didn't break.

I am using paramiko to login a server with user 'xyz' and then 'su -' using paramiko channel.

  1. ssh = paramiko.SSHClient()
  2. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  3. try:
  4.     ssh.connect(hostname, username='xyz', password=list_pass(hostname, 'xyz'))
  6.     command = 'puppet agent -t --no-use_cached_catalog ; echo COMMAND_COMPLETED'
  8.     channel = ssh.invoke_shell()
  9.     channel.send("su -\n")
  10.     time.sleep(2)
  11.     channel.send(list_pass(hostname, 'root') + "\n")
  12.     time.sleep(2)
  13.     channel.send(command + '\n')
  14.     time.sleep(5)
  16.     while True:
  17.         if channel.recv:
  18.             time.sleep(1)
  19.             print(channel.recv(1024).decode())
  20.             if "COMMAND_COMPLETED" in channel.recv(1024).decode():
  21.                 break
  22.         else:
  23.             continue
  25.     channel.close()
  26.     ssh.close()
  28. except paramiko.AuthenticationException:
  29.     print("Authentication failed")
  30. except socket.gaierror:
  31.     print(f"Can't connect to {hostname}. Verify if server exists and it's up.")

This code went to infinite loop. Command still running.

enter image description here

答案1

得分: 0

我尝试了下面的代码，它有效。

  1. channel.send(command + '\n')
  2. time.sleep(5)
  3. # 创建一个新的接收缓冲区
  4. receive_buffer = ""
  6. while not receive_buffer.endswith("# ") or receive_buffer.endswith("$ "):
  7.     '''
  8.     'root' 用户提示以 '# ' 结尾。
  9.     'non-root' 用户提示以 '$ ' 结尾。
  10.     '''
  11.     receive_buffer += channel.recv(9999).decode()
  13. print(receive_buffer)
  14. channel.close()
  15. ssh.close()

请注意，我保留了代码中的注释以提供更多上下文。

英文:

I tried below code and it worked.

  1. channel.send(command + '\n')
  2. time.sleep(5)
  3. # Create a new receive buffer
  4. receive_buffer = ""
  6. while not receive_buffer.endswith("# ") or receive_buffer.endswith("$ "):
  7.     '''
  8.     'root' user prompt ends with '# '.
  9.     'non-root' user prompt end with '$ '.
  10.     '''
  11.     receive_buffer += channel.recv(9999).decode()
  13. print(receive_buffer)
  14. channel.close()
  15. ssh.close()

huangapple
  • 本文由 发表于 2023年5月21日 00:11:54
  • 转载请务必保留本文链接：https://go.coder-hub.com/76296156.html
  • paramiko
  • python
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定