|
@@ -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)
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
client.switch_user(user, password)
|
|
|
|
|
|
|
|
@@ -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)
|