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),