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

fix influxdb

Browse Source
This commit is contained in:
anlicheng 2024-09-03 14:45:28 +08:00
parent 5b9675ba7f
commit 4883a5d519
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -91,7 +91,8 @@ 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),
%% 创建特殊的buckets %% 创建特殊的buckets
SuperDeviceUUIDs = iot_env:get_value(super_device_uuids, []), SuperDeviceUUIDs = iot_env:get_value(super_device_uuids, []),
catch create_buckets(PoolPid, SuperDeviceUUIDs), Result = catch create_buckets(PoolPid, SuperDeviceUUIDs),
lager:debug("[influx_client_pool] create buckets result is: ~p", [Result]),
{ok, #state{pool_pid = PoolPid}}. {ok, #state{pool_pid = PoolPid}}.