fix(dynamo): fix field name errors

2023-04-20 18:16:04 +08:00 · 2023-04-20 18:16:04 +08:00 · 21473e7ca5
parent adc422d063
commit 21473e7ca5
1 changed files with 2 additions and 2 deletions
--- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl
+++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_dynamo.erl
@ -107,7 +107,7 @@ on_start(

    Templates = parse_template(Config),
    State = #{
-        poolname => InstanceId,
+        pool_name => InstanceId,
        table => Table,
        templates => Templates
    },
@ -176,7 +176,7 @@ do_query(
    InstanceId,
    Query,
    ApplyMode,
-    #{poolname := PoolName, templates := Templates, table := Table} = State
+    #{pool_name := PoolName, templates := Templates, table := Table} = State
 ) ->
    ?TRACE(
        "QUERY",