从python将csv数据导入influxdb

我在.csv文件中有timeseries这样的数据。该数据没有标题，但是这是在不同的领域有：date,time,open,high,low,close,volume,0

2017-09-22,21:50:00,131.36,131.415,131.35,131.39,78489,0 
2017-09-22,21:55:00,131.39,131.4,131.37,131.38,95322,0 
2017-09-22,22:00:00,131.38,131.6,131.31,131.39,1212804,0

我试图将此数据从python导入InfluxDB。我在文档中看到，您必须为它逐行创建json，但我不确定这是如何完成的：

这很接近，但没有雪茄。假设我已经将字符串拆分并且datetime-timestamp已经采用了正确的格式。当我打印下面的json_body时，我得到例如：

[{'fields': {'Int_value': '1212804', 'Float_value': '131.39'}, 'time': datetime.datetime(2017, 9, 22, 22, 0), 'measurement': 'quote'}]

这似乎不正确 - 我似乎只得到一个浮点值。

输入到InfluxDB的正确JSON是什么？

import datetime 
import random 
import time 
import os 
import csv 
from csv import reader 
import argparse 
from influxdb import client as influxdb 


db = influxdb.InfluxDBClient("127.0.0.1", 8086, "", "", "stocks") 


def read_data(filename): 
    print filename 
    with open(filename) as f: 
     lines = f.readlines()[1:] 

    return lines 

if __name__ == '__main__': 
    filename = r"jnj.us.csv" 
    lines = read_data(filename) 
    for rawline in lines: 
     line = rawline.split(",") 
     d= getPythonDateTimeFromStr(line[0], line[1]) 
     #EVERYTHING UP TO HERE WORKS. Not sure how to create the json below 
     #==================================== 
     json_body = [ 
     { 
      "measurement": "quote", 
      "time": d, 
      "fields": { 
       "Float_value": line[2], 
       "Float_value": line[3], 
       "Float_value": line[4], 
       "Float_value": line[5], 
       "Int_value": line[6] 
      } 
     } 
     ] 

     print json_body 

     db.write_points(json_body)

来源

2017-09-23 Ivan

咄，

"fields": { 
      "Float_value": line[2], 
      "Float_value": line[3], 
      "Float_value": line[4], 
      "Float_value": line[5], 
      "Int_value": line[6] 
}

应该

"fields": { 
      "Open": line[2], 
      "High": line[3], 
      "Low": line[4], 
      "Close": line[5], 
      "Volume": line[6] 
}

来源

2017-09-24 01:36:26 Ivan

从python将csv数据导入influxdb

回答

相关问题