import MySQLdb
import socket, sys
from struct import *
import threading
import sched, time
from datetime import datetime
from copy import deepcopy
import Queue
IP = {}
class QP:

 def __init__(self):


   self.jobs = Queue.Queue()




 def processQueue(self):

        print(self.jobs.qsize())
        time.sleep(5)


        if self.jobs.empty():
         print("No items in queue")

        else:



           IP_TEMP = {}
           IP_TEMP = self.jobs.get();
           IP_TEMP_QUEUE = {}
           IP_TEMP_QUEUE = IP_TEMP


           try:
            cnx = //connect
            cursor = cnx.cursor()



            for k, v in IP_TEMP.iteritems():

                //code

                try:
                 cursor.execute(add_packet, data_packet)
                 cnx.commit()

                 print("Task Done")





                except:
                 print("Query failed, skipping")
                 break

           except:
             self.queueJobs(IP_TEMP_QUEUE)







           IP = {}
           self.jobs.task_done()
        self.processQueue()


 def queueJobs(self, data):

    self.jobs.put(data)
    print(self.jobs.qsize())



    return True;