import psycopg2

def generateDicts(log_fh):
    currentDict = {}
    a = []
    for line in log_fh:
        #currentDict = {"IP":line.split(" ")[0], "DATE":line.split(" ")[1]}
        #ip =["IP:"+line.split(" ")[0],"DATE:" + line.split(" ")[1]]
        ip = [line.split(" ")[0], line.split(" ")[3], line.split(" ")[8],line.split(" ")[9]]
        a.append(ip)

    return a

count = 0

with open("/home/stiv/working/drug-abook.access.log") as f:
   for line in list(generateDicts(f)):
       ip = line[0]
       date = line[1]
       code = int(line[2])
       bytes = int(line[3])
       #print line


       conn = psycopg2.connect("dbname='logs_nginx' user='pit' host='localhost' password='123'")
       cur = conn.cursor()
       query = "INSERT INTO logs (ip, date, code, bytes) VALUES (%s, %s, %s, %s);"
       data = (ip, date, code, bytes)
       cur.execute(query, data)
       count=count +1

       conn.commit()

print count