瀏覽代碼

Merge pull request #12683 from kjellwinblad/kjell/kinesis2/fix/parameter_restrictions/EMQX-11983

fix(Amazon Kinesis Action): batch size restriction
Kjell Winblad 1 年之前
父節點
當前提交
93903eb04b
共有 1 個文件被更改,包括 16 次插入1 次删除
  1. 16 1
      apps/emqx_bridge_kinesis/src/emqx_bridge_kinesis.erl

+ 16 - 1
apps/emqx_bridge_kinesis/src/emqx_bridge_kinesis.erl

@@ -62,7 +62,19 @@ fields(kinesis_action) ->
                 required => true,
                 desc => ?DESC("action_parameters")
             }
-        )
+        ),
+        #{
+            resource_opts_ref => hoconsc:ref(?MODULE, action_resource_opts)
+        }
+    );
+fields(action_resource_opts) ->
+    emqx_bridge_v2_schema:action_resource_opts_fields(
+        _Overrides = [
+            {batch_size, #{
+                type => range(1, 500),
+                validator => emqx_resource_validator:max(int, 500)
+            }}
+        ]
     );
 fields("config_producer") ->
     emqx_bridge_schema:common_bridge_fields() ++
@@ -84,6 +96,7 @@ fields("resource_opts") ->
 fields("creation_opts") ->
     emqx_resource_schema:create_opts([
         {batch_size, #{
+            type => range(1, 500),
             validator => emqx_resource_validator:max(int, 500)
         }}
     ]);
@@ -199,6 +212,8 @@ desc(action_parameters) ->
     ?DESC("action_parameters");
 desc(connector_resource_opts) ->
     ?DESC(emqx_resource_schema, "resource_opts");
+desc(action_resource_opts) ->
+    ?DESC(emqx_resource_schema, "resource_opts");
 desc(_) ->
     undefined.