yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(emqx_ee_connector): log reason for failure when starting influxdb connector

This commit is contained in:
Erik Timan 2023-02-01 14:32:46 +01:00
parent 812a87841b
commit 603532dacd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
View File

@ -234,7 +234,7 @@ do_start_client(
) -> ) ->
case influxdb:start_client(ClientConfig) of case influxdb:start_client(ClientConfig) of
{ok, Client} -> {ok, Client} ->
case influxdb:is_alive(Client) of case influxdb:is_alive(Client, true) of
true -> true ->
State = #{ State = #{
client => Client, client => Client,
@ -249,13 +249,13 @@ do_start_client(
state => redact_auth(State) state => redact_auth(State)
}), }),
{ok, State}; {ok, State};
false -> {false, Reason} ->
?tp(influxdb_connector_start_failed, #{error => influxdb_client_not_alive}), ?tp(influxdb_connector_start_failed, #{error => influxdb_client_not_alive}),
?SLOG(warning, #{ ?SLOG(warning, #{
msg => "starting influxdb connector failed", msg => "starting influxdb connector failed - client is not alive",
connector => InstId, connector => InstId,
client => redact_auth(Client), client => redact_auth(Client),
reason => "client is not alive" reason => Reason
}), }),
%% no leak %% no leak
_ = influxdb:stop_client(Client), _ = influxdb:stop_client(Client),