SSH Connection Closed While Looping over a command list #689
Comments
|
The code you posted got mangled, so it's hard to see what the indentation was. However, assuming that had the calls to Your options are to either do a separate If you look through the closed issues here, you'll see a number of examples about different ways of handling this. One example is #121. Another example is #227, and there are probably others as well as this topic comes up repeatedly. Unfortunately, there's no simple answer here. It really depends on the device and your ability to get the device to output something unique enough at the end of each command's output to give you a reliable indicator of when it is safe to send the next command. For instance, if you can configure a unique prompt on the device which won't show up in the command output, you can do a |
|
I tried the #121 below it didnt work. The device is a Cisco IOS XE. I need your guidance please. My plan is to capture the output of each command in the list and save as a key to a dictionary. example is `async def get_show_using_asynssh(dict_data: dict): Below is the error I got.` 1941 bytes read on a total of undefined expected bytes Thanks for your help! |
|
The error you're seeing generally indicates that you received an end-of-file from the remote system before getting the prompt you told it to look for. I don't see the definition of PROMPT in the sample code above, but make sure that the remote system actually does output a prompt, and that you set PROMPT to match whatever it prints when command output ends and it is ready to receive a new command. Also, for this to work, you shouldn't be providing a command. You need it to open an interactive shell, which occurs when you call |
|
It seems there is no straight forward solution for this just like we use Netmiko or Paramiko for Cisco device. Asynssh works with Juniper but this issue with Cisco is major one. It will be good if you have a solution for this. I have edited the code. I now get some data from the command output but not all. I dont the the output of show vlan command. Am I missing anything here? PROMPT = r'#' |
|
By any chance, does any of the output in any of the commands contain '#' in the output? If so, your prompt isn't unique enough to work reliably. I also see what looks like a typo in the "terminal length 0" command string. That might prevent you from getting to a prompt if the amount of output is larger than the default terminal length. |
|
Below is the prompt after login and after command output. cisco_switch_prompt# 'terminal length 0' in cisco allows you to display ouput without breaks below is an example of command and output; thanks for your time |
Yes, I understand. My point was that your sample code included 'terminal lenght 0' instead of 'terminal length 0'. This would cause it to try and paginate the output, probably causing it to stop before it got back to the prompt. This would make the I would also set PROMPT to something more than just '#', unless you're sure that none of the commands you were running would ever include a '#' in their output. |
|
Sorry I didnt get you here |
|
By the way I see this as part of the output
|
|
Take a look at your sample code above. One of the lines is: process.stdin.write('terminal lenght 0' + '\n')This appears to be a typo in the command you are trying to run to disable pagination. |
|
Oh I see it now ht vs th........ Thanks so much I got it to work now by adding 'terminal length 0' to the list of command Thanks for helping me see this through. I performed the operation on 150 switches and my result is Asynssh is way better and faster. Thanks so much. |
|
Glad to hear you got it working! Also, thanks for sharing the results of your performance tests... That's a pretty nice improvement! Opening many connections at once is definitely one of AsyncSSH's strengths, as it doesn't require separate processes (or threads per connection (or even per session) the way most SSH client libraries do. If you are running on a multi-core client, you can improve performance even more by running multiple event loops at once, but you only want a small number of threads (one per available core) in that case, rather than opening a separate process or thread for each connection. |
|
How can I run multiple event loops at once? example Thanks |
|
I don't have an example handy, and it can get pretty involved depending on how independent your tasks are, but it basically involves using the "multiprocessing" library to create a pool of processes, letting each process create its own asyncio event loop, and then dividing up the work you are doing so that is gets spread across the multiple threads. For example, let's say that you knew up front what the 150 servers were you wanted to pull data from, and you wanted to spread the work across 5 cores. You could simply break the list of servers into 5 lists of 30 servers each, and then you could create 5 separate processes and feed each process one of the 5 lists. In your main process, you'd call join() on each of the 5 processes, collecting the results from each until you had all 150 responses. Fancier versions of this could involve having a multiprocess queue, where you have your main task add work items to the queue and let the child processes pull work off the queue, writing the results back to another multiprocess queue, where you limit the number of asyncio tasks each process starts pulling work from the pool until it hits some limit on the number of concurrent tasks you want it to start. After that, each task that completes would trigger it to get another one until the queue was exhausted. I don't have any direct experience with it, but you might want to experiment with https://aiomultiprocess.omnilib.dev/en/stable/guide.html to do some of the work for you, providing an easy way to schedule async tasks across multiple processes. |
With respect to below, ssh connection closes after the first command. This works with Juniper device but failed with Cisco devices.
Am I missing something? It is looking like there is an exit after the first command.
async def get_show_using_asynssh(dict_data: dict):
async with asyncssh.connect(host=dict_data["ip_address"], username=dict_data["username"], password=dict_data["password"],
known_hosts=None) as conn:
output = {}
commands = ['show mac address-table', 'show lldp neighbors detail', 'show vlan']
try:
for cmd in commands: # this is a multiple command coroutine
out = (await conn.run(cmd, term_size=(5000000000, 2400000), check=True)).stdout
if out:
output[cmd.split()[1]] = out
else:
output[cmd.split()[1]] = ''
print('Finished send command string.............')
The text was updated successfully, but these errors were encountered: