python 将nginx日志写得mysql

#/usr/bin/env python

#-*-coding:UTF-8 -*-

from  datetime \nimport  datetime

import   pymysql

connect=pymysql.connect(

   host='127.0.0.1',

   port=3306,

   user='root',

   password='',

   database='nginxlog',

   charset="utf8"

)

cur =\nconnect.cursor()

sql= "insert\ninto nginxlog(ip,time,methods,source,protocol,status)\nvalues(%s,%s,%s,%s,%s,%s)"

with\nopen("D:/tools/nginx-1.17.9/logs\\host.access.log","r")  as \nngfile:

   for line in ngfile:

      _nodes = line.split()

      IP= _nodes[0]

      Time=\n_nodes[3][1:-1].replace(":"," ",1) #将时间转换为17/Jun/2017 12:43:4格式

      Time =\ndatetime.strptime(Time,"%d/%b/%Y %H:%M:%S")#将时间格式化为2017-06-17 12:43:04

      Methods = _nodes[5][1:]

      Source = _nodes[6]

      Protocol = _nodes[7][:-1]

      Status = _nodes[8]

     \nprint(IP,Time,Methods,Source,Protocol,Status)

     \ncur.execute(sql,(IP,Time,Methods,Source,Protocol,Status))

      connect.commit()

\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n

   connect.close()