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

fix(Dynamo): fix DynamoDB bridge status check error

This commit is contained in:
firest 2023-04-24 17:28:33 +08:00
parent 988e4ec1aa
commit 7ce04358c4
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl
View File

@ -34,7 +34,7 @@
-import(hoconsc, [mk/2, enum/1, ref/2]). -import(hoconsc, [mk/2, enum/1, ref/2]).
-define(DYNAMO_HOST_OPTIONS, #{ -define(DYNAMO_HOST_OPTIONS, #{
default_port => 8000 default_port => 80
}). }).
%%===================================================================== %%=====================================================================

10
lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo_client.erl
View File

@ -71,8 +71,14 @@ init(#{
{ok, #{}}. {ok, #{}}.
handle_call(is_connected, _From, State) -> handle_call(is_connected, _From, State) ->
_ = erlcloud_ddb2:list_tables(), IsConnected =
{reply, true, State}; case erlcloud_ddb2:list_tables([{limit, 1}]) of
{ok, _} ->
true;
_ ->
false
end,
{reply, IsConnected, State};
handle_call({query, Table, Query, Templates}, _From, State) -> handle_call({query, Table, Query, Templates}, _From, State) ->
Result = do_query(Table, Query, Templates), Result = do_query(Table, Query, Templates),
{reply, Result, State}; {reply, Result, State};