From 9d17bf31f812495f261b696e1d041533804f1ad7 Mon Sep 17 00:00:00 2001
From: JimMoen <LnJimMoen@outlook.com>
Date: Tue, 9 Aug 2022 14:28:54 +0800
Subject: [PATCH] fix: InfluxDB api v1 not support uint type

---
 lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_influxdb.erl | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_influxdb.erl b/lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_influxdb.erl
index 490abfc09..83c5a4127 100644
--- a/lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_influxdb.erl
+++ b/lib-ee/emqx_ee_bridge/src/emqx_ee_bridge_influxdb.erl
@@ -49,6 +49,12 @@ conn_bridge_examples(Method) ->
 values(Protocol, get) ->
     maps:merge(values(Protocol, post), ?METRICS_EXAMPLE);
 values(Protocol, post) ->
+    case Protocol of
+        "influxdb_api_v2" ->
+            SupportUint = <<"uint_value=${payload.uint_key}u">>;
+        _ ->
+            SupportUint = <<>>
+    end,
     #{
         type => list_to_atom(Protocol),
         name => <<"demo">>,
@@ -58,7 +64,7 @@ values(Protocol, post) ->
         local_topic => <<"local/topic/#">>,
         write_syntax =>
             <<"${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}">>
     };
 values(Protocol, put) ->