回答此问题可获得 20 贡献值,回答如果被采纳可获得 50 分。
<p>我是InfluxDB中的新成员,问题在于我必须通过Nifi在InfluxDB中插入python dicts,我尝试了不同的方法,但总是收到相同的错误,提示标记丢失:</p>
<p><a href="https://i.stack.imgur.com/rfIkV.png" rel="nofollow noreferrer"><img src="https://i.stack.imgur.com/rfIkV.png" alt="enter image description here"/></a></p>
<pre><code>org.influxdb.InfluxDBException: {
"error": "unable to parse '[
{
"measurement": "sensor",
"time": 1559560006,
"tags": [
"sensor",
"id",
"date",
"info",
"aleatory_number",
"aleatory_number_square_root"
],
"fields": {
"id": 8,
"date": 1559559961002,
"info": "info sensor8",
"aleatory_number": 1778687859,
"aleatory_number_square_root": 42174.492
}
}
]': missing tag value"
}
</code></pre>
<p>另一个例子:</p>
^{pr2}$
<p>另一个:</p>
<pre><code>org.influxdb.InfluxDBException:
{
"error":"unable to parse
'[{
"measurement":"sensor",
"time":1559631341,
"tags":{},
"fields":{}
}]'
: missing tag value"}
</code></pre>
<p>我的最后一次尝试遵循以下avro模式:</p>
<pre><code>{
"type": "record",
"name": "preprocessed_value",
"fields": [
{ "name": "measurement", "type": "string" },
{ "name": "time", "type": "long" },
{ "name": "tags", "type": { "type":"map", "values" : "string"} },
{
"name" : "fields" ,
"type" : {
"name" : "PythonDict",
"type" : "record",
"fields": [
{ "name": "id", "type": "int" },
{ "name": "date", "type": "long" },
{ "name": "info", "type": "string" },
{ "name": "aleatory_number", "type": "long" },
{ "name": "aleatory_number_square_root", "type": "float" }
]
}
}
]
}
</code></pre>
<p>同时使用标记和字段时,我也遇到了同样的错误:</p>
<pre><code>org.influxdb.InfluxDBException: {"error":"unable to parse
'[{
"measurement":"sensor",
"time":1559720142,
"tags":{"test_tag":"test"},
"fields":{
"id":3,
"date":1559718332366,
"info":"info sensor3",
"aleatory_number":141969819,
"aleatory_number_square_root":11915.108
}
}]': missing tag value"}
</code></pre>