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

fix monitor influxdb

Browse Source
This commit is contained in:
anlicheng 2025-04-08 11:11:43 +08:00
parent f8f659a957
commit 80c3508072
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/iot/src/influxdb/influx_monitor_client_pool.erl
View File

@ -77,10 +77,7 @@ init([]) ->
%% 启动工作的线程池 %% 启动工作的线程池
{ok, PoolPid} = poolboy:start_link([{size, PoolSize}, {max_overflow, PoolSize}, {worker_module, influx_client}], WorkerArgs), {ok, PoolPid} = poolboy:start_link([{size, PoolSize}, {max_overflow, PoolSize}, {worker_module, influx_client}], WorkerArgs),
%% 创建bucket %% 创建bucket
poolboy:transaction(PoolPid, fun(ClientPid) -> poolboy:transaction(PoolPid, fun(ClientPid) -> create_bucket(ClientPid) end),
Result = create_bucket(ClientPid),
lager:debug("[influx_monitor_client_pool] org_name: ~p, create bucket result: ~p", [?DEFAULT_ORG, Result])
end),
%% 定时刷新逻辑 %% 定时刷新逻辑
erlang:start_timer(5000, self(), flush_ticker), erlang:start_timer(5000, self(), flush_ticker),