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

Merge pull request #13537 from thalesmg/20240729-r57-auto-decode-payload-kprodu 

feat: attempt to automatically decode `payload` similar to key and message templates
This commit is contained in:
zmstone 2024-07-29 21:03:41 +02:00 committed by GitHub
parent 60aefd1065 693d5dd394
commit 5b50d5433a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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">>),