Python пихаем csv файл в Influxdb

import argparse
import csv
import os
from influxdb import InfluxDBClient
import zipfile
import itertools
 
 
 
PATH = '.\\....zip'
MEASUREMENT = 'all'
TAGS = ('name','form_id')
FIELDS = {'reqh':int, 'users':int,}
DELIMIIER = ';'
 
client = InfluxDBClient(host='...', port=8086, username='...', password='....', database='....')
 
def translate_label(a):
    if 'NFLX query email password' in a['name']:
        return None
    if 'Set Start Annotation' in a['name']:
        return None
    if 'STS ADD message_id.csv' in a['name']:
        return None
    if 'STS READ' in a['name']:
        return None
    a['name'] = a['name'].replace('<_','').strip('-').strip('.').strip()
    #a['responseMessage'] = a['responseMessage'].replace('Non HTTP response code: ','')
    return a
 
 
def dict2db(ln, project_name, tags, fields):
    json_body = {
            'measurement': MEASUREMENT,
            'tags': dict([(t,ln.get(t,'')) for t in tags]),
            'time': ln.get('timeStamp','0'),
            'fields': dict([(f, fields[1][f](ln.get(f,'0'))) for f in fields])
    }
    return json_body
def import_db(path2file, project_name_tbl, tags, fields, chunk = 10000, translate_label={}):
    
   
    counter = 0
    lst = []
    if zipfile.is_zipfile(path2file):
        zp = zipfile.ZipFile(path2file, mode='r')
        memberlist = [fn for fn in zp.namelist() if not fn.endswith('/') ]
        for name_file in memberlist:
            if not name_file.endswith('.csv'):
                continue
            with zp.open(name_file, 'r') as csvfile:
                reader = csv.DictReader(csvfile, delimiter=DELIMIIER)
                
                for i, val in enumerate(reader):
                    try:
                        val = translate_label(val)
                        if val is None:
                            continue
 
                        val['timeStamp'] = i
                    
                        lst.append(dict2db(val, project_name_tbl, tags, fields))
                    except Exception as e:
                        print ('line not save')
                        print (val)
                        print (e)
                        print ("+"*40)
                    counter+=1
                    # заливаем файл в базу частями, т.к. построчно - это очень долго, а весь файл целом 
                    if counter%chunk == 0:
                        client.write_points(lst)
                        lst = []
                        print ('.'),
        # заливаем последную часть данных
        if lst !=[] :
            client.write_points(lst)
            lst = []
            print ('the end')
            print (counter)
 
 
import_db(PATH, MEASUREMENT, FIELDS, TAGS, chunk = 1000, translate_label=translate_label)
 
print 'Done'
 
from os import system
system("pause")