Merge pull request #12497 from SergeTupchiy/EMQX-11825-mongodb-connector-perf-rel55

mongodb connector perf (release-55)
This commit is contained in:
SergeTupchiy 2024-02-09 16:52:19 +02:00 committed by GitHub
commit 9ec7393ba5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 8 additions and 21 deletions

View File

@ -4,5 +4,5 @@
{deps, [
{emqx_connector, {path, "../../apps/emqx_connector"}},
{emqx_resource, {path, "../../apps/emqx_resource"}},
{mongodb, {git, "https://github.com/emqx/mongodb-erlang", {tag, "v3.0.22"}}}
{mongodb, {git, "https://github.com/emqx/mongodb-erlang", {tag, "v3.0.23"}}}
]}.

View File

@ -1,6 +1,6 @@
{application, emqx_mongodb, [
{description, "EMQX MongoDB Connector"},
{vsn, "0.1.5"},
{vsn, "0.1.6"},
{registered, []},
{applications, [
kernel,

View File

@ -131,8 +131,8 @@ fields(topology) ->
hoconsc:mk(
pos_integer(),
#{
deprecated => {since, "5.1.1"},
importance => ?IMPORTANCE_HIDDEN
importance => ?IMPORTANCE_HIDDEN,
default => 10
}
)},
{max_overflow, fun max_overflow/1},
@ -201,23 +201,7 @@ on_start(
false ->
[{ssl, false}]
end,
Topology0 = maps:get(topology, NConfig, #{}),
%% we fix this at 1 because we already have ecpool
case maps:get(pool_size, Topology0, 1) =:= 1 of
true ->
ok;
false ->
?SLOG(
info,
#{
msg => "mongodb_overriding_topology_pool_size",
connector => InstId,
reason => "this option is deprecated; please set `pool_size' for the connector",
value => 1
}
)
end,
Topology = Topology0#{pool_size => 1},
Topology = maps:get(topology, NConfig, #{}),
Opts = [
{mongo_type, init_type(NConfig)},
{hosts, Hosts},

View File

@ -0,0 +1,3 @@
Improve MongoDB connector performance.
- [mongodb-erlang PR](https://github.com/emqx/mongodb-erlang/pull/41)