Browse Source

Merge pull request #4 from nickidw/master

Update csv-to-influxdb.py
Fabio Miranda 5 years ago
parent
commit
0a3ea4a019
1 changed files with 5 additions and 5 deletions
  1. 5 5
      csv-to-influxdb.py

+ 5 - 5
csv-to-influxdb.py

@@ -40,10 +40,10 @@ def loadCsv(inputfilename, servername, user, password, dbname, metric, timecolum
     port = int(servername[servername.rfind(':')+1:])
     client = InfluxDBClient(host, port, user, password, dbname)
 
-    print('Deleting database %s'%dbname)
-    client.drop_database(dbname)
-    print('Creating database %s'%dbname)
-    client.create_database(dbname)
+    #print('Deleting database %s'%dbname)
+    #client.drop_database(dbname)
+    #print('Creating database %s'%dbname)
+    #client.create_database(dbname)
     client.switch_user(user, password)
 
     # format tags and fields
@@ -155,4 +155,4 @@ if __name__ == "__main__":
     args = parser.parse_args()
     loadCsv(args.input, args.server, args.user, args.password, args.dbname, 
         args.metricname, args.timecolumn, args.timeformat, args.tagcolumns, 
-        args.fieldcolumns, args.gzip, args.delimiter, args.batchsize)
+        args.fieldcolumns, args.gzip, args.delimiter, args.batchsize)