从 python 将 csv 数据导入 influxdb

Question

几乎肯定有人问过这个问题。

我在 .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 )

Answer 1

呃，

"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]
 }

从 python 将 csv 数据导入 influxdb

Import csv data into influxdb from python

influxdb-python