From 7ce04358c411ba85e9fdb6f5154d56daaf89a8ab Mon Sep 17 00:00:00 2001 From: firest Date: Mon, 24 Apr 2023 17:28:33 +0800 Subject: [PATCH] fix(Dynamo): fix DynamoDB bridge status check error --- .../emqx_ee_connector/src/emqx_ee_connector_dynamo.erl | 2 +- .../src/emqx_ee_connector_dynamo_client.erl | 10 ++++++++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl index 2170827d6..01554f90a 100644 --- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl +++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl @@ -34,7 +34,7 @@ -import(hoconsc, [mk/2, enum/1, ref/2]). -define(DYNAMO_HOST_OPTIONS, #{ - default_port => 8000 + default_port => 80 }). %%===================================================================== diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo_client.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo_client.erl index e0d8ee4bf..0340655b4 100644 --- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo_client.erl +++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo_client.erl @@ -71,8 +71,14 @@ init(#{ {ok, #{}}. handle_call(is_connected, _From, State) -> - _ = erlcloud_ddb2:list_tables(), - {reply, true, State}; + IsConnected = + case erlcloud_ddb2:list_tables([{limit, 1}]) of + {ok, _} -> + true; + _ -> + false + end, + {reply, IsConnected, State}; handle_call({query, Table, Query, Templates}, _From, State) -> Result = do_query(Table, Query, Templates), {reply, Result, State};