anlicheng/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix influxdb

Browse Source
This commit is contained in:
anlicheng 2023-08-28 16:39:17 +08:00
parent dbba46a334
commit a54a42e236
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/iot/src/influxdb/influx_client.erl
View File

@ -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} ->