compare two different paragraph line by line in Python

from difflib import HtmlDiff

text_A= """
1) line number 1
2) line number 2
3) line number n
"""

text_B= """
2) line number 2
3) line number n
4) line number raghu
"""




delta_html = HtmlDiff().make_file(text_A.splitlines(),
                                  text_B.splitlines())

with open('diff.html', 'w') as f:
     f.write(delta_html)

compare two different files line by line in Python

import difflib
from difflib import HtmlDiff

with open('show_run_SW-VSS_2019-02-05.txt') as f1:
    f1_text = f1.read()
with open('show_run_SW-VSS_2019-02-01.txt') as f2:
    f2_text = f2.read()



delta_html = HtmlDiff().make_file(f1_text.splitlines(),
                                  f2_text.splitlines())

with open('diff22.html', 'w') as f:
     f.write(delta_html)

mongo db query ( group , aggregate ) to fetch latest network backup

 db.backup.aggregate({$unwind: '$backupDoc'},{$match: { "backupDoc.status": "success" }},{$group: {"_id" : "$deviceIp",lastdate: {$max: "$backupDoc.datetime"}}

Checking Firewall Status and Stopping Firewall in centos

[root@DSCenWeb01 ~]# sudo firewall-cmd --state
running
[root@DSCenWeb01 ~]# sudo systemctl stop firewalld

Celery Beat To Schedule Multiple Tasks

CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Kolkata'
CELERY_BEAT_SCHEDULE = {
    'NetworkBackup': {
      'task': 'NetworkAutomation.views.bkpSchedule',
      #'schedule': timedelta(seconds=3600),
      'schedule': crontab(minute=0, hour="*/6"),
    },
    'copyBkpFromAnsibletoJenkins': {
      'task': 'NetworkAutomation.views.copyBkpFromAnsibletoJenkins',
      #'schedule': crontab(minute="*/3"),
      'schedule': crontab(minute=0, hour="*/1"),
    },
    'copyBkpFromJenkinstoDjango': {
      'task': 'NetworkAutomation.views.copyBkpFromJenkinstoDjango',
      #'schedule': crontab(minute="*/2"),
      'schedule': crontab(minute=0, hour="*/1"),
    },

}

SCP to Copy all files inside a directory from remote linux host using sshpass

 "sshpass -p '<password>' scp -r root@<remoteIP>:<sourcepath> <destinationpath>"

Django Celery task to copy file from remote host using SCP and SSHPASS

@task()
def copyBkpFromJenkinstoDjango():
       ip = ''
       port = ""
       username = ""
       password = ""
       cmd = "sshpass -p '<password>' scp -r root@<remoteIP>:/root/networkBackups /root/Django"
       #print (cmd)
       ssh=paramiko.SSHClient()
       ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
       ssh.connect(ip,port,username,password)
       stdin,stdout,stderr=ssh.exec_command(cmd)
       time.sleep(50)
       outlines=stdout.readlines()
       resp =''.join(outlines)
       #print(resp)
       return resp

Moving all files from one directory to another using Python

import shutil

import os

source = '/path/to/source_folder'

dest1 = '/path/to/dest_folder'

files = os.listdir(source)

for f in files:

        shutil.move(source+f, dest1)

Python script to trigger ansible playbook via SSH using paramiko SSH Client

       cmd = "ansible-playbook " +  <playbookname> + " -vvvv"
       print (cmd)
       ssh=paramiko.SSHClient()
       ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
       ssh.connect(ip,port,username,password)
       stdin,stdout,stderr=ssh.exec_command(cmd)
       time.sleep(50)
       outlines=stdout.readlines()
       resp =''.join(outlines)
       print(resp)
       return resp

Python Script to create File and append 10 dummy lines on every function call

def createFolder():
   try:
        if not os.path.exists(directory):
            os.makedirs(directory)
            return 'FolderCreated'
            return 'FolderNotCreated'

     f = open("/home/raghu/Desktop/raghu1234.txt","a+")

     for i in range(10):
        f.write("This is the line %d\r\n" % (i+1))

     f.close()

# FunctionCall
createFolder()

Get Result from Jenkins Job via API

                output = 'curl http://<jenkinsUserName>:<jenkinsPassword>@<jenkinsIP>:<jenkinsPort>/job/<JobName>/<BuildNumber>/consoleText'

                jobout = subprocess.check_output(output, shell=True)

                print (jobout)

Trigger a ansible playbook via jenkins using jenkins API

 'curl -d ' + finalString + ' -i -X POST http://admin:<adminpassword>@<JenkinsIP>:<PortNumber>/job/<JobName>/buildWithParameters -H "Jenkins-Crumb:<crumbID>"'

finalString =   inputs for the ansible script in this format example - "ticketnumber=d" -d "deviceType=yj" -d "createnewpool=kug" -d "server=k" -d "node=y" -d "poolname=y" -d "port=y" -d "modificationtype=yy" -d "partition=yy" -d "lb_method=yy" -d "slowramptime=yy"

Django to trigger ansible playbook via (python paramiko.SSHClient()) SSH (take input from template and display result in other template )

def backupPage(request):
        my_form3 = Backup()
        if request.method == 'POST' and 'NetworkBackup' in request.POST:

            my_form3 = Backup(request.POST)
            if my_form3.is_valid():
                ticketnumber = my_form3.cleaned_data['ticketNumber']
                ip = my_form3.cleaned_data['ansibleServerIP']
                port = my_form3.cleaned_data['ansibleServerPort']
                username = my_form3.cleaned_data['ansibleServerUsername']
                password = my_form3.cleaned_data['ansibleServerPassword']
                cmd = my_form3.cleaned_data['playbookFullPath']
                minutes = my_form3.cleaned_data['TimerInMinutes']
                #occurence = my_form3.cleaned_data['TimerInMinutes']
                f = open("/home/raghu/Desktop/Backup/" + ticketnumber + ".txt","a+")
                f.write(ticketnumber + " " + ip + " " + port + " " + " " + username + " " + password + " " + cmd)
                f.close()
                time.sleep(5)
                latestFiles = glob.glob('/home/raghu/Desktop/Backup/*')
                latestFile = max(latestFiles, key=os.path.getctime)
                print (latestFile)

                a = schedule1()
                return render(request, "mail.html" , { 'form1': a })

                #schedule.every(minutes).minutes.do(schedule1)
                #while True:
                #    schedule.run_pending()
                #    time.sleep(1)

        return render(request, "backupPage.html" , { 'form3': my_form3 })

def schedule1():
       latestFiles = glob.glob('/home/raghu/Desktop/Backup/*')
       latestFile = max(latestFiles, key=os.path.getctime)
       #print latestFile
       #f.close()
       filename = latestFile;
       f = open(filename,"r")
       temp = f.read()
       words = temp.split()
       ip = words[1]
       port = words[2]
       username = words[3]
       password = words[4]
       cmd1 = words[5]
       cmd = "ansible-playbook " + cmd1 + " -vvvv"
       print (cmd)
       ssh=paramiko.SSHClient()
       ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
       ssh.connect(ip,port,username,password)
       stdin,stdout,stderr=ssh.exec_command(cmd)
       time.sleep(50)
       outlines=stdout.readlines()
       resp =''.join(outlines)
       print(resp)
       return resp

Django Get request from template and pass value to views function and display result in template

def get(request):

        my_form1 = PoolModification()
        my_form2 = OnboardingDevice()

        if request.method == 'POST' and 'PoolModification' in request.POST:
        #Post request to handle form upload
            my_form1 = PoolModification(request.POST) #Bind data from request.POST to poolModification form
            if my_form1.is_valid():

                finalString1 = '" -d "'.join("{!s}={!s}".format(key,val) for (key,val) in my_form1.cleaned_data.items())
                finalString = '"{}"'.format(finalString1)
                print (finalString)
                response = 'curl -d ' + finalString + ' -i -X POST http://admin:02bab31633994212cd@192.168.10.12:8080/job/pool-modification/buildWithParameters -H "Jenkins-Crumb:90eed10ddeafaf555"'

                os.system(response)

                time.sleep(60)
                output = 'curl http://admin:02bab3161694212cd@192.168.10.12:8080/job/pool-modification/lastBuild/consoleText'

                jobout = subprocess.check_output(output, shell=True)

                print (jobout)


                return render(request, "mail.html" , { 'form1' :jobout })
                #time.sleep(50)
                #def mails(jobout):
                #    return render(request, "mails.html" , {'form3' : jobout})
                #return HttpResponseRedirect(request, "createpost.html" , {'form1' : my_form1})

        elif request.method == 'POST' and 'OnboardingDevice' in request.POST:
        #Post request to handle form upload
            my_form2 = OnboardingDevice(request.POST) #Bind data from request.POST to poolModification form
            if my_form2.is_valid():

                finalString1 = '" -d "'.join("{!s}={!s}".format(key,val) for (key,val) in my_form2.cleaned_data.items())
                finalString = '"{}"'.format(finalString1)
                print (finalString)
                response = 'curl -d ' + finalString + ' -i -X POST http://admin:02bab3163391694212cd@192.168.10.12:8080/job/OnboardingDevice/buildWithParameters -H "Jenkins-Crumb:90eed1049263ddeafaf555"'

                os.system(response)
                time.sleep(50)
                output = 'curl http://admin:02bab3161694212cd@192.168.10.12:8080/job/OnboardingDevice/lastBuild/consoleText'
                jobout = os.system(output)
                print (jobout)
                return render(request, "mail.html" , {'form2' : my_form2})

            else:
                print(my_form.errors)

        return render(request, "ChangeAutomation.html" , { 'form1' :my_form1, 'form2' :my_form2 })

Django setting.py celery beat configuration to trigger a function at every time interval

CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Kolkata'
CELERY_BEAT_SCHEDULE = {
    'createFolder': {
      'task': 'catalog.views.createFolder',
      'schedule': timedelta(seconds=30),

    }
}