From a54a42e23669744ca8429269e015fb8bc020a834 Mon Sep 17 00:00:00 2001 From: anlicheng Date: Mon, 28 Aug 2023 16:39:17 +0800 Subject: [PATCH] fix influxdb --- apps/iot/src/influxdb/influx_client.erl | 2 ++ 1 file changed, 2 insertions(+) diff --git a/apps/iot/src/influxdb/influx_client.erl b/apps/iot/src/influxdb/influx_client.erl index 19f9a34..0e32f59 100644 --- a/apps/iot/src/influxdb/influx_client.erl +++ b/apps/iot/src/influxdb/influx_client.erl @@ -56,6 +56,8 @@ write_data(Measurement, Tags, FieldsList, Timestamp) when is_binary(Measurement) %% 按照设备的uuid进行分组 Points = lists:map(fun(Fields) -> NFields = case Fields of + #{<<"key">> := Key, <<"value">> := Value, <<"unit">> := Unit, <<"name">> := Name, <<"label">> := Label} -> + #{Key => jiffy:encode(#{<<"value">> => Value, <<"unit">> => Unit, <<"name">> => Name, <<"label">> => Label}, [force_utf8])}; #{<<"key">> := Key, <<"value">> := Value, <<"unit">> := Unit} -> #{Key => jiffy:encode(#{<<"value">> => Value, <<"unit">> => Unit}, [force_utf8])}; #{<<"key">> := Key, <<"value">> := Value} ->