3

私はこの[3526 rows x 5 columns]DFを持っています。col0時間col1-col3はタグでcol4あり、私の値です。

                    0             1                  2         3      4
0     2017-09-29 22:41:51     10.2.95.5   C1195_LF470_SARF   0.0.1.1  11993
1     2017-09-29 22:41:37     10.2.52.7   CF643_RCZ70_SARM  0.0.1.16  12102
2     2017-09-29 22:41:39    10.2.102.7   C1345_BQS70_SARF  0.0.1.17  18173
3     2017-09-29 22:41:41   10.2.23.212   CN165_FS470_SAR8   0.0.0.7  23525
4     2017-09-29 22:41:38     10.2.96.4   CF832_UY570_SARM   0.0.1.4   6162

だから、そのDFをinfluxdbに書きたい。やります ...

timeValues  = df[ ['col0','col4'] ]
tags        = { 'col1': df[['col1']], 'col2': df[['col2']], 'col3':df[['col3']] }

dbConnDF = DataFrameClient(dbAddress, dbPort, dbUser, dbPassword, dbName)
dbConnDF.write_points(dbName, tbName, timeValues, tags = tags)

その後、エラーが発生します

Datetime または PeriodIndex を含む DataFrame である必要があります

ただし、これを使用して行ごとに挿入すると...

dbConnQRY = InfluxDBClient(dbAddress, dbPort, dbUser, dbPassword, dbName)
dbConnQRY.write_points(bodyDB)

どこ:

bodyDB = [{
    "measurement": tbName,
    "tags":
    {
        "col1": col1,
        "col2": col2,
        "col3": col3
    },
    "time": col0,
    "fields":
    {
        "col4": col4
    }
}]

...エラーはまったく発生しません。そのため、DF全体を一度に挿入しようとすると問題が発生します。

col0エラーを回避するために、これが私のインデックスであることを influxdb に伝えるにはどうすればよいですか?

ありがとう!

4

1 に答える 1