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

feat: attempt to automatically decode `payload` similar to key and message templates

This commit is contained in:
Thales Macedo Garitezi 2024-07-29 11:37:33 -03:00
parent 60aefd1065
commit 693d5dd394
2 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_bridge_kafka/src/emqx_bridge_kafka_impl_producer.erl
View File

@ -469,7 +469,7 @@ render_topic({fixed, KafkaTopic}, _Message) ->
KafkaTopic; KafkaTopic;
render_topic({dynamic, Template}, Message) -> render_topic({dynamic, Template}, Message) ->
try try
iolist_to_binary(emqx_template:render_strict(Template, Message)) iolist_to_binary(emqx_template:render_strict(Template, {emqx_jsonish, Message}))
catch catch
error:_Errors -> error:_Errors ->
throw(bad_topic) throw(bad_topic)

7
apps/emqx_bridge_kafka/test/emqx_bridge_v2_kafka_producer_SUITE.erl
View File

@ -967,12 +967,7 @@ t_dynamic_topics(Config) ->
RuleTopic, RuleTopic,
[ [
{bridge_name, ActionName} {bridge_name, ActionName}
], ]
#{
sql =>
<<"select *, json_decode(payload) as payload from \"", RuleTopic/binary,
"\" ">>
}
), ),
?assertStatusAPI(Type, ActionName, <<"connected">>), ?assertStatusAPI(Type, ActionName, <<"connected">>),