ファンダスDF with tags with influxdb

Question

私はこれを持っています[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) 

その後、私はエラーMust be DataFrame with Datetime or PeriodIndexを得ます。しかし

、私はこれを使用して行で行の挿入を行う場合...

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に教えてください。

ありがとうございます！インデックスの問題を解決する必要があり

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

続い

Answer 1

Create an index column for dataframe 
timeValues = df[ ['col4'] ] 
timeValues.index = df[ ['col0'] ] 

。