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

fix influx_client_pool

Browse Source
This commit is contained in:
anlicheng 2024-09-03 17:09:33 +08:00
parent 7cf373e04f
commit db2144642b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -128,7 +128,7 @@ handle_cast({write_data, _Bucket, []}, State) ->
{noreply, State}; {noreply, State};
handle_cast({write_data, Bucket, Points}, State = #state{pool_pid = PoolPid, buffers = Buffers}) -> handle_cast({write_data, Bucket, Points}, State = #state{pool_pid = PoolPid, buffers = Buffers}) ->
Q = maps:get(Bucket, Buffers, queue:new()), 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), Len = queue:len(NQ),