kennyh 2 周之前
父節點
當前提交
4e4399d2a9
共有 1 個文件被更改,包括 8 次插入2 次删除
  1. 8 2
      apps/emqx_bridge_http/src/emqx_bridge_http_connector.erl

+ 8 - 2
apps/emqx_bridge_http/src/emqx_bridge_http_connector.erl

@@ -405,7 +405,7 @@ on_query(
                 reason => Reason,
                 connector => InstId
             }),
-            Result;
+Result;
         _Success ->
             Result
     end.
@@ -713,9 +713,15 @@ render_request_body(BodyTks, RenderTmplFunc, Msg) ->
 
 encode_payload_with_base64(Msg) ->
     Payload = maps:get(payload, Msg, <<>>),
+    PayloadHex = binary_to_hex(Payload),
+    ?SLOG(debug, #{msg => "encode_payload_with_base64", payload_hex => PayloadHex, payload_size => byte_size(Payload)}),
     Base64Payload = base64:encode(Payload),
+    ?SLOG(debug, #{msg => "encode_payload_with_base64", Base64Payload => Base64Payload}),
     maps:put(payload, Base64Payload, Msg).
 
+% 辅助函数:将二进制数据转换为16进制字符串
+binary_to_hex(Bin) ->
+    lists:flatten([io_lib:format("~2.16.0B", [Byte]) || <<Byte>> <= Bin]).
 render_headers(HeaderTks, RenderTmplFunc, Msg) ->
     lists:map(
         fun({K, V}) ->
@@ -915,4 +921,4 @@ join_paths_test_() ->
         ?_assertEqual("abc///cde/", join_paths("abc//", "//cde/"))
     ].
 
--endif.
+-endif.