yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: InfluxDB api v1 not support uint type

This commit is contained in:
JimMoen 2022-08-09 14:28:54 +08:00
parent d51ca2672a
commit 9d17bf31f8
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_influxdb.erl
View File

@ -49,6 +49,12 @@ conn_bridge_examples(Method) ->
values(Protocol, get) -> values(Protocol, get) ->
maps:merge(values(Protocol, post), ?METRICS_EXAMPLE); maps:merge(values(Protocol, post), ?METRICS_EXAMPLE);
values(Protocol, post) -> values(Protocol, post) ->
case Protocol of
"influxdb_api_v2" ->
SupportUint = <<"uint_value=${payload.uint_key}u">>;
_ ->
SupportUint = <<>>
end,
#{ #{
type => list_to_atom(Protocol), type => list_to_atom(Protocol),
name => <<"demo">>, name => <<"demo">>,
@ -58,7 +64,7 @@ values(Protocol, post) ->
local_topic => <<"local/topic/#">>, local_topic => <<"local/topic/#">>,
write_syntax => write_syntax =>
<<"${topic},clientid=${clientid}", " ", "payload=${payload},", <<"${topic},clientid=${clientid}", " ", "payload=${payload},",
"${clientid}_int_value=${payload.int_key}i,", "uint_value=${payload.uint_key}u,", "${clientid}_int_value=${payload.int_key}i,", SupportUint/binary,
"bool=${payload.bool}">> "bool=${payload.bool}">>
}; };
values(Protocol, put) -> values(Protocol, put) ->