您需要编写一个脚本来将您的CSV转换为OpenTSDB格式的内容。 OpenTSDB的一般格式是 metric timestamp value tags
metric timestamp value tags
例如,您的样本可以写成如下:
stock.open 1041269400 24.53 symbol=XXX stock.high 1041269400 24.65 symbol=XXX stock.low 1041269400 24.53 symbol=XXX stock.close 1041269400 24.65 symbol=XXX stock.volume 1041269400 762200 symbol=XXX stock.open 1041269460 24.65 symbol=XXX stock.high 1041269460 24.68 symbol=XXX stock.low 1041269460 24.52 symbol=XXX stock.close 1041269460 24.6 symbol=XXX stock.volume 1041269460 90400 symbol=XXX
虽然看起来你的工作时间是1分钟,但开放/关闭是多余的,所以这可能更合适:
stock.quote.1m 1041269340 24.53 symbol=XXX stock.quote.1m 1041269400 24.65 symbol=XXX stock.quote.1m 1041269460 24.6 symbol=XXX
我为opentsdb写了一个小的csv导入器。
https://github.com/soeren-lubitz/csv-to-opentsdb
它适用于CSV格式的文件
Timestamp,Foo,Bar 1483342774,42.1,23.2
希望这可以帮助。反馈将不胜感激。