fix loggers
This commit is contained in:
parent
e2f54d21e0
commit
4afa622732
@ -10,9 +10,34 @@
|
|||||||
-export([start/2, stop/1]).
|
-export([start/2, stop/1]).
|
||||||
|
|
||||||
start(_StartType, _StartArgs) ->
|
start(_StartType, _StartArgs) ->
|
||||||
|
start_logger(),
|
||||||
aircon_sup:start_link().
|
aircon_sup:start_link().
|
||||||
|
|
||||||
stop(_State) ->
|
stop(_State) ->
|
||||||
ok.
|
ok.
|
||||||
|
|
||||||
%% internal functions
|
%% internal functions
|
||||||
|
|
||||||
|
start_logger() ->
|
||||||
|
%filelib:ensure_dir("log/debug.log"),
|
||||||
|
|
||||||
|
logger:add_handler(
|
||||||
|
disk,
|
||||||
|
logger_disk_log_h,
|
||||||
|
#{
|
||||||
|
level => debug,
|
||||||
|
file => "log/debug.log",
|
||||||
|
size => 10485760,
|
||||||
|
max_no_files => 5,
|
||||||
|
formatter => {logger_formatter, #{template => "$time [$level] $message $metadata\n"}}
|
||||||
|
}
|
||||||
|
),
|
||||||
|
|
||||||
|
logger:add_handler(
|
||||||
|
default_console,
|
||||||
|
logger_std_h,
|
||||||
|
#{
|
||||||
|
level => debug,
|
||||||
|
formatter => {logger_formatter, #{template => "$time [$level] $message $metadata\n"}}
|
||||||
|
}
|
||||||
|
).
|
||||||
@ -185,14 +185,16 @@ emqx_opts(ClientSuffix) when is_binary(ClientSuffix) ->
|
|||||||
|
|
||||||
-spec dispatch(DeviceMac :: binary(), Message :: binary()) -> no_return().
|
-spec dispatch(DeviceMac :: binary(), Message :: binary()) -> no_return().
|
||||||
dispatch(DeviceMac, Message) when is_binary(DeviceMac), is_binary(Message) ->
|
dispatch(DeviceMac, Message) when is_binary(DeviceMac), is_binary(Message) ->
|
||||||
case aircon_args:get_device_uuid(DeviceMac) of
|
logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]),
|
||||||
error ->
|
ok.
|
||||||
logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]);
|
%case aircon_args:get_device_uuid(DeviceMac) of
|
||||||
{ok, DeviceUUID} ->
|
% error ->
|
||||||
case aircon_device_sup:ensure_device_started(DeviceUUID) of
|
% logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]);
|
||||||
{ok, DevicePid} ->
|
% {ok, DeviceUUID} ->
|
||||||
aircon_device:metric_data(DevicePid, Message);
|
% case aircon_device_sup:ensure_device_started(DeviceUUID) of
|
||||||
{error, Reason} ->
|
% {ok, DevicePid} ->
|
||||||
logger:notice("[mqtt_subscriber] start device get error: ~p", [Reason])
|
% aircon_device:metric_data(DevicePid, Message);
|
||||||
end
|
% {error, Reason} ->
|
||||||
end.
|
% logger:notice("[mqtt_subscriber] start device get error: ~p", [Reason])
|
||||||
|
% end
|
||||||
|
%end.
|
||||||
@ -36,23 +36,23 @@ init([]) ->
|
|||||||
RegisterName = read_service_name(),
|
RegisterName = read_service_name(),
|
||||||
|
|
||||||
ChildSpecs = [
|
ChildSpecs = [
|
||||||
%#{
|
#{
|
||||||
% id => 'efka_client',
|
id => 'efka_client',
|
||||||
% start => {'efka_client', start_link, [RegisterName, Host, Port]},
|
start => {'efka_client', start_link, [RegisterName, Host, Port]},
|
||||||
% restart => permanent,
|
restart => permanent,
|
||||||
% shutdown => 2000,
|
shutdown => 2000,
|
||||||
% type => worker,
|
type => worker,
|
||||||
% modules => ['efka_client']
|
modules => ['efka_client']
|
||||||
%},
|
},
|
||||||
|
|
||||||
%#{
|
#{
|
||||||
% id => 'aircon_args',
|
id => 'aircon_args',
|
||||||
% start => {'aircon_args', start_link, []},
|
start => {'aircon_args', start_link, []},
|
||||||
% restart => permanent,
|
restart => permanent,
|
||||||
% shutdown => 2000,
|
shutdown => 2000,
|
||||||
% type => worker,
|
type => worker,
|
||||||
% modules => ['aircon_args']
|
modules => ['aircon_args']
|
||||||
%},
|
},
|
||||||
|
|
||||||
#{
|
#{
|
||||||
id => aircon_logger,
|
id => aircon_logger,
|
||||||
@ -99,7 +99,7 @@ read_service_name() ->
|
|||||||
%% 获取配置的名称
|
%% 获取配置的名称
|
||||||
RootDir = code:root_dir(),
|
RootDir = code:root_dir(),
|
||||||
VersionFile = RootDir ++ "/.version",
|
VersionFile = RootDir ++ "/.version",
|
||||||
logger:debug("[aircon_sup] version path is: ~p", [VersionFile]),
|
logger:info("[aircon_sup] version path is: ~p", [VersionFile]),
|
||||||
case file:read_file(VersionFile) of
|
case file:read_file(VersionFile) of
|
||||||
{ok, RegisterName0} ->
|
{ok, RegisterName0} ->
|
||||||
string:trim(RegisterName0);
|
string:trim(RegisterName0);
|
||||||
|
|||||||
@ -14,24 +14,9 @@
|
|||||||
]},
|
]},
|
||||||
|
|
||||||
{efka_server, [
|
{efka_server, [
|
||||||
{host, "39.98.184.67"},
|
{host, "118.178.229.213"},
|
||||||
{port, 3361}
|
{port, 3361}
|
||||||
]}
|
]}
|
||||||
]},
|
|
||||||
|
|
||||||
{logger, [
|
|
||||||
{level, debug},
|
|
||||||
{metadata, [device_id, request_id]},
|
|
||||||
{handlers, [
|
|
||||||
{default, logger_std_h, #{level => debug,
|
|
||||||
formatter => {logger_formatter, #{template => "$time [$level] $message $metadata\n"}}}},
|
|
||||||
|
|
||||||
{disk, logger_disk_log_h, #{level => debug,
|
|
||||||
file => "log/debug.log",
|
|
||||||
size => 10485760,
|
|
||||||
max_no_files => 5,
|
|
||||||
formatter => {logger_formatter, #{template => "$time [$level] $message $metadata\n"}}}}
|
|
||||||
]}
|
|
||||||
]}
|
]}
|
||||||
|
|
||||||
].
|
].
|
||||||
@ -17,21 +17,5 @@
|
|||||||
{host, "39.98.184.67"},
|
{host, "39.98.184.67"},
|
||||||
{port, 3361}
|
{port, 3361}
|
||||||
]}
|
]}
|
||||||
]},
|
|
||||||
|
|
||||||
{logger, [
|
|
||||||
{level, debug},
|
|
||||||
{metadata, [device_id, request_id]},
|
|
||||||
{handlers, [
|
|
||||||
{default, logger_std_h, #{level => info,
|
|
||||||
formatter => {logger_formatter, #{template => "$time [$level] $message $metadata\n"}}}},
|
|
||||||
|
|
||||||
{disk, logger_disk_log_h, #{level => debug,
|
|
||||||
file => "log/debug.log",
|
|
||||||
size => 10485760,
|
|
||||||
max_no_files => 5,
|
|
||||||
formatter => {logger_formatter, #{template => "$time [$level] $message $metadata\n"}}}}
|
|
||||||
]}
|
]}
|
||||||
]}
|
|
||||||
|
|
||||||
].
|
].
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user