Merge tag 'v4.3.15-rc.5' into merge-main-v4.3-into-v4.4
This commit is contained in:
commit
9c91788a9e
|
@ -29,7 +29,7 @@
|
||||||
|
|
||||||
-ifndef(EMQX_ENTERPRISE).
|
-ifndef(EMQX_ENTERPRISE).
|
||||||
|
|
||||||
-define(EMQX_RELEASE, {opensource, "4.4.4-rc.4"}).
|
-define(EMQX_RELEASE, {opensource, "4.4.4-rc.5"}).
|
||||||
|
|
||||||
-else.
|
-else.
|
||||||
|
|
||||||
|
|
|
@ -701,7 +701,7 @@ end}.
|
||||||
#{
|
#{
|
||||||
date_format => DateFormat,
|
date_format => DateFormat,
|
||||||
template =>
|
template =>
|
||||||
[" [",level,"] ",
|
[time," [",level,"] ",
|
||||||
{clientid,
|
{clientid,
|
||||||
[{peername,
|
[{peername,
|
||||||
[clientid,"@",peername," "],
|
[clientid,"@",peername," "],
|
||||||
|
|
|
@ -32,13 +32,18 @@ check_config(Config0) ->
|
||||||
Config = maps:without([date_format], Config0),
|
Config = maps:without([date_format], Config0),
|
||||||
logger_formatter:check_config(Config).
|
logger_formatter:check_config(Config).
|
||||||
|
|
||||||
format(#{msg := Msg0, meta := Meta} = Event,
|
format(Event, Config) ->
|
||||||
#{date_format := rfc3339, template := Template0} = Config) ->
|
case maps:get(date_format, Config, rfc3339) of
|
||||||
|
rfc3339 ->
|
||||||
|
format(Event, Config, rfc3339);
|
||||||
|
DateFormatString ->
|
||||||
|
format(Event, Config, DateFormatString)
|
||||||
|
end.
|
||||||
|
|
||||||
|
format(#{msg := Msg0, meta := Meta} = Event, Config, rfc3339) ->
|
||||||
Msg = maybe_merge(Msg0, Meta),
|
Msg = maybe_merge(Msg0, Meta),
|
||||||
Template = [time | Template0],
|
logger_formatter:format(Event#{msg := Msg}, Config);
|
||||||
logger_formatter:format(Event#{msg := Msg}, Config#{template => Template});
|
format(#{msg := Msg0, meta := Meta} = Event, #{template := Template} = Config, DFS) ->
|
||||||
format(#{msg := Msg0, meta := Meta} = Event,
|
|
||||||
#{date_format := DFS} = Config) ->
|
|
||||||
Msg = maybe_merge(Msg0, Meta),
|
Msg = maybe_merge(Msg0, Meta),
|
||||||
Time =
|
Time =
|
||||||
case maps:get(time, Event, undefined) of
|
case maps:get(time, Event, undefined) of
|
||||||
|
@ -48,7 +53,10 @@ format(#{msg := Msg0, meta := Meta} = Event,
|
||||||
T
|
T
|
||||||
end,
|
end,
|
||||||
Date = emqx_calendar:format(Time, microsecond, local, DFS),
|
Date = emqx_calendar:format(Time, microsecond, local, DFS),
|
||||||
[Date | logger_formatter:format(Event#{msg := Msg}, Config)].
|
[Date | logger_formatter:format(Event#{msg := Msg}, Config#{template => remove_time(Template)})].
|
||||||
|
|
||||||
|
remove_time([time | Tail]) -> Tail;
|
||||||
|
remove_time(Template) -> Template.
|
||||||
|
|
||||||
maybe_merge({report, Report}, Meta) when is_map(Report) ->
|
maybe_merge({report, Report}, Meta) when is_map(Report) ->
|
||||||
{report, maps:merge(Report, filter(Meta))};
|
{report, maps:merge(Report, filter(Meta))};
|
||||||
|
|
Loading…
Reference in New Issue