Advertisement
Guest User

Untitled

a guest
Apr 6th, 2017
91
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.24 KB | None | 0 0
  1. Mysql
  2.  
  3. real: 6m 39sec
  4. user: 2.956sec
  5. sys: 0.504sec
  6.  
  7. Influxdb
  8.  
  9. real: 6m 17.193sec
  10. user: 11.860sec
  11. sys: 0.328sec
  12.  
  13. #!/usr/bin/env python
  14. # coding: utf-8
  15. import time
  16. import csv
  17. import sys
  18. import datetime
  19. import calendar
  20. import pytz
  21. from influxdb import client as influxdb
  22. from datetime import datetime
  23.  
  24. host = 'localhost'
  25. port = 8086
  26. user = "admin"
  27. password = "admin"
  28. db_name = "testdatabase"
  29. db = influxdb.InfluxDBClient(database=db_name)
  30.  
  31.  
  32. def read_data():
  33. with open(file) as f:
  34. reader = f.readlines()[4:]
  35. for line in reader:
  36. yield (line.strip().split(','))
  37.  
  38.  
  39. fmt = '%Y-%m-%d %H:%M:%S'
  40. file = '/home/rob/mycsvfile.csv'
  41.  
  42. csvToInflux = read_data()
  43. for metric in csvToInflux:
  44. timestamp = datetime.strptime(metric[0][1: len(metric[0]) - 1], fmt)
  45.  
  46. new_value = float(metric[1])
  47. influx_metric = [{
  48. 'measurement': 'mytable1',
  49. 'time': timestamp,
  50. 'fields': {
  51. 'col1': metric[1],
  52. 'col2': metric[2],
  53. 'col3': metric[3],
  54. 'col4': metric[4],
  55. 'col5': metric[5],
  56. 'col6': metric[6],
  57. 'col7': metric[7],
  58. 'col8': metric[8],
  59. 'col9': metric[9]
  60. }
  61. }]
  62. db.write_points(influx_metric)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement