From db2144642b508ea7d2fed11e413a4f6b12efeb41 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Tue, 3 Sep 2024 17:09:33 +0800
Subject: [PATCH] fix influx_client_pool

---
 apps/iot/src/influxdb/influx_client_pool.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apps/iot/src/influxdb/influx_client_pool.erl b/apps/iot/src/influxdb/influx_client_pool.erl
index 9137063..13591a5 100644
--- a/apps/iot/src/influxdb/influx_client_pool.erl
+++ b/apps/iot/src/influxdb/influx_client_pool.erl
@@ -128,7 +128,7 @@ handle_cast({write_data, _Bucket, []}, State) ->
     {noreply, State};
 handle_cast({write_data, Bucket, Points}, State = #state{pool_pid = PoolPid, buffers = Buffers}) ->
     Q = maps:get(Bucket, Buffers, queue:new()),
-    NQ = lists:foldl(fun(Point, Q0) -> queue:in(Point, Q0) end, Q, Points),
+    NQ = queue:join(Q, queue:from_list(Points)),
 
     %% 超过缓冲区设置的大小则批量导入
     Len = queue:len(NQ),