Using input from csv to run commands against network devices

<pre class="wp-block-code"><code>#!/usr/bin/env python

'''
Takes input from the ports.csv file and will update the ports based on what is in the csv
'''

from multiprocessing import Process, Queue
from datetime import datetime
from netmiko import ConnectHandler
from ntc_templates.parse import parse_output
import csv
from getpass import getpass

ssh_pass = getpass("Enter ssh password: ")


def show_cisco_commands(a_device, output_q, intf, vlan, description):
    """
    Use Netmiko to execute commands. Use a queue to pass the data back to
    the main process.
    """
    config_commands = (&#091; 'interface '+ intf, 
                    'switchport access vlan '+ vlan, 
                    'description '+ description ])
 
    output_dict = {}
    
    remote_conn = ConnectHandler(**a_device)
    print(remote_conn.base_prompt)
    print(remote_conn.send_config_set(config_commands))
    output_q.put(output_dict)



def main():
    start_time = datetime.now()
    output_q = Queue(maxsize=20)

    procs = &#091;]

    with open('ports.csv', mode='r') as csv_file:
        csv_reader = csv.DictReader(csv_file)
        line_count = 0
        for row in csv_reader:
            if line_count == 0:
                ", ".join(row)
                line_count += 1
            line_count += 1
            '''
            In this section you can specify any different values from the csv file
            you may want to add in. Perhaps one for enabled/disabled.
            '''
            hostname = row&#091;"hostname"]
            port = row&#091;"interface"]
            vlan = row&#091;"vlan"]
            desc = row&#091;"description"]
            cisco = {
                'device_type': 'cisco_ios',
                'host': hostname,
                'username': 'USERNAME',
                'password': ssh_pass,
                }
            my_proc = Process(target=show_cisco_commands, args=(cisco, output_q, port, vlan, desc))
            my_proc.start()
            procs.append(my_proc)

    # Make sure all processes have finished
    for a_proc in procs:
        a_proc.join()


    print("\nElapsed time: " + str(datetime.now() - start_time))


if __name__ == "__main__":
    main()</code></pre>
<!-- /wp:code -->

<pre class="wp-block-code"><code>    print(remote_conn.base_prompt)
    print(remote_conn.send_config_set(config_commands))</code></pre>
<!-- /wp:code -->