Das deutsche Python-Forum

Code: Alles auswählen

##########################################################################
#  Setup
##########################################################################

    def setUp(self):

        self.s = testcore.control.ssh.SSH(host='xxx.xxx.xxx.xxx',
                                      username='admin', password='admin', type_of_dut='ecos')
        logger.info('self.s = testcore.control.ssh.SSH')
        self.s.query_interactive=True


        if self.s.login():
            logger.info('login')
            q = self.s.query('account')
            logger.info('account')
            self.assertIsNotNone(q, 'missing answer')
            self.assertEqual('\r\n', q, 'unexpected result')
            logger.info('missing answer')
            logger.info('unexpected result')

            # switch to prompt account

            q=self.s.query('enforce-Password-Rules yes')
            logger.info('enforce-Password-Rules yes')
            q=self.s.query('exit')
            logger.info('exit')

    def tearDown(self):
        self.s.close()


        #########################################################################
        # Test 1 create external NTP Server http://www.pool.ntp.org/zone/de IP v4
        #########################################################################

    def test_create_ntp_external1(self):
        logger_true.info('test_create_ntp_external')
        if self.s.loggedin:
            logger.info('self.s.loggedin')
            q = self.s.query('time')
            logger.info('time')
            self.assertIsNotNone(q, 'missing answer')
            self.assertEqual('\r\n', q, 'unexpected result')
            logger.info('missing answer')
            logger.info('unexpected result')

            # switch to prompt account

            q = self.s.query('ntp 1 94.16.116.137')
            logger.info('ntp 1 94.16.116.137')
            q = self.s.query('exit')
            self.assertIsNotNone(q, 'missing answer')
            self.assertEqual('\r\n', q, 'unexpected result')
            logger.info('missing answer')
            logger.info('unexpected result')

            q = self.s.query('logout')
            logger.info('logout')

            import time
            print('Wait')
            time.sleep(2)
            print('True')
            logger_true.info('True')
            self.s.close()

Code: Alles auswählen

import sys, os, string, threading
import paramiko

cmd = "grep -h 'king' /opt/data/horror_20100810*"

outlock = threading.Lock()

def workon(host):

    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect(host, username='xy', password='xy')
    stdin, stdout, stderr = ssh.exec_command(cmd)
    stdin.write('xy\n')
    stdin.flush()

    with outlock:
        print stdout.readlines()

def main():
    hosts = ['10.10.3.10', '10.10.4.12', '10.10.2.15', ] # etc
    threads = []
    for h in hosts:
        t = threading.Thread(target=workon, args=(h,))
        t.start()
        threads.append(t)
    for t in threads:
        t.join()

main()

Code: Alles auswählen

import yaml

def send_ssh_cmd(host, username, password, commands):
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect(host, username=username, password=password)
    for command in commands:
    	stdin, stdout, stderr = ssh.exec_command(command)
        ....
    


def send_telnet_cmd():
    pass

....

def main(devices):
    for host in devices['switch']:
        if devices['switch'][host]['connection'] == 'ssh':
            send_ssh_cmd(devices['switch'][host]['hostname'],
                        devices['switch'][host]['ip'],
                        devices['switch'][host]['commands'],
                            )
        elif ...


if __name__ == '__main__':
    with open('devices.yml', 'r') as input_file:
        devices = yaml.load(input_file)
    main(devices)

Code: Alles auswählen

switch:
  01:
    hostname: 'core01.inside.example'
    ip: '10.0.0.1'
    connection: 'ssh'
    vendor: 'cisco xyz'
    commands:
      - 'do something'
  02:
    hostname: 'edge01.inside.example'
    ip: '172.16.0.2'
    connection: 'ssh'
    vendor: 'juniper xyz'
    commands:
      - 'set ntp server 172.20.X.Y\r\n'
      - 'set ntp server 172.22.X.Y\r\n'