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

fix(kafka): data backup, support old strategy style

This commit is contained in:
DDDHuang 2022-06-22 11:03:34 +08:00
parent daa87e525f
commit 6cf583a301
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/emqx_management/src/emqx_mgmt_data_backup.erl
View File

@ -206,6 +206,22 @@ import_rule(#{<<"id">> := RuleId,
map_to_actions(Maps) ->
[map_to_action(M) || M <- Maps].
map_to_action(Map = #{<<"id">> := ActionInstId,
<<"name">> := <<"data_to_kafka">>,
<<"args">> := Args}) ->
NArgs =
case maps:get(<<"strategy">>, Args, undefined) of
<<"first_key_dispatch">> ->
%% Old version(4.2.x) is first_key_dispatch.
%% Now is key_dispatch.
Args#{<<"strategy">> => <<"key_dispatch">>};
_ ->
Args
end,
#{id => ActionInstId,
name => 'data_to_kafka',
args => NArgs,
fallbacks => map_to_actions(maps:get(<<"fallbacks">>, Map, []))};
map_to_action(Map = #{<<"id">> := ActionInstId, <<"name">> := Name, <<"args">> := Args}) ->
#{id => ActionInstId,
name => any_to_atom(Name),