【发布时间】:2021-03-09 16:28:45
【问题描述】:
我正在尝试将一些传感器数据写入 InfluxDB。客户端没有返回错误,但没有数据访问数据库。你能帮我一把吗?我玩了标签,不同的,时间格式等等,但无济于事。我读了我能找到的东西,但不知何故我迷路了。 我正在使用 InfluxDB 1.8.3,
def create_dictionary_for_value(temperature,humidity):
return [{
"measurement": "kojiboxclimate",
"tags": {
"host": "server01",
"region": "us-west"
},
"time": datetime.datetime.utcnow().isoformat(),
"fields": {
"temperature": temperature,
"humidity": humidity
}
}]
def main():
client = InfluxDBClient(HOST, PORT, USER, PASSWORD, DBNAME)
retention_policy = 'my_policy'
client.create_retention_policy(retention_policy, '3d', 3, default=True)
while True:
temperature, humidity = sensor.read()
payload = create_dictionary_for_value(temperature, humidity)
print("{}\n".format(payload))
client.write_points(payload, retention_policy=retention_policy, protocol='json')
result = client.query('select value from kojiboxclimate;')
print("Result: {0}".format(result))
time.sleep(60)
有效载荷的输出产生了我所期望的:
[{“字段”:{“温度”:20.164034485389493,“湿度”: 38.62821393148699},“标签”:{“主机”:“server01”,“区域”:“美国西部”},“时间”:“2020-11-26T19:00:15.042571”,“测量”: 'kojiboxclimate'}]
结果集是空的,db也是。
【问题讨论】: