--- metadata: - name: generator content: Diplodoc Platform v5.50.4 alternate: - https://ydb.tech/docs/en/recipes/ydb-sdk/session-pool-limit.md - https://ydb.tech/docs/ru/recipes/ydb-sdk/session-pool-limit.md sourcePath: ru/core/recipes/ydb-sdk/session-pool-limit.md --- > **Documentation Index:** Fetch the complete configuration index at https://ydb.tech/docs/ru/llms.txt # Установить размер пула сессий YDB создаёт [актор](https://ydb.tech/docs/ru/concepts/glossary.md#actor) для каждой сессии. В результате, размер пула сессий на клиенте влияет на потребление ресурсов (память, процессор) на серверной стороне YDB. Например, если 1000 клиентов одной базы данных открывают по 1000 сессий, то на серверной стороне создаётся 1000000 акторов. Такое количество акторов потребляет значительные объёмы памяти и ресурсов процессора. При отсутствии ограничения на число сессий на клиенте это может привести к медленной работе кластера и его полуаварийному состоянию. По умолчанию в YDB SDK при использовании нативных драйверов установлен лимит в 50 сессий. При использовании сторонних библиотек, например, Go `database/sql`, лимит не задан. Рекомендуется устанавливать лимит на количество сессий на клиенте в минимально необходимый для штатной работы клиентского приложения. Следует учитывать, что сессия однопоточная как на серверной, так и на клиентской стороне. Соответственно, если для расчётной нагрузки приложению требуется выполнять 1000 одновременных запросов (inflight) в YDB, то лимит следует установить на уровне 1000 сессий. Важно различать расчётный RPS (requests per second, запросов в секунду) и inflight. В первом случае речь идёт об общем количестве запросов, выполняемых к YDB за 1 секунду. Например, при RPS = 10000 и средней задержке исполнения запроса (latency) в 100 мс достаточно установить лимит в 1000 сессий. Это означает, что каждая сессия за расчётную секунду выполнит в среднем 10 последовательных запросов. Ниже приведены примеры кода установки лимита на пул сессий в разных YDB SDK. {% list tabs %} - C++ {% list tabs %} - Native SDK - `MaxActiveSessions` — максимальный размер пула (по умолчанию 50). - `MinPoolSize` — минимальное число сессий (по умолчанию 10). SDK перестанет закрывать сессии по таймауту по достижении лимита, поэтому число не гарантированное. ```cpp #include #include NYdb::NQuery::TQueryClient CreateQueryClient(const NYdb::TDriver& driver) { NYdb::NQuery::TClientSettings settings; settings.SessionPoolSettings( NYdb::NQuery::TSessionPoolSettings() .MaxActiveSessions(500) .MinPoolSize(10)); return NYdb::NQuery::TQueryClient(driver, settings); } ``` - userver {% cut "static config" %} ```yaml ydb: databases: db: endpoint: grpc://localhost:2136 database: /local max_pool_size: 500 min_pool_size: 10 ``` {% endcut %} Код инициализации `ydb::YdbComponent`, получения `ydb::TableClient` и запуска `components::MinimalServerComponentList` — как в примере из [init.md](https://ydb.tech/docs/ru/recipes/ydb-sdk/init.md). {% endlist %} - Go {% list tabs %} - Native SDK ```golang package main import ( "context" "github.com/ydb-platform/ydb-go-sdk/v3" ) func main() { db, err := ydb.Open(ctx, os.Getenv("YDB_CONNECTION_STRING"), ydb.WithSessionPoolSizeLimit(500), ) if err != nil { panic(err) } defer db.Close(ctx) ... } ``` - database/sql Библиотека `database/sql` имеет свой пул соединений. Каждое соединение в `database/sql` соответствует конкретной сессии YDB. Управлением пулом соединений в `database/sql` осуществляется с помощью функций `sql.DB.SetMaxOpenConns` и `sql.DB.SetMaxIdleConns`. Подробнее об этом написано в [документации](https://pkg.go.dev/database/sql#DB.SetMaxOpenConns) `database/sql`. Пример кода, использующего размер пула соединений `database/sql`: ```golang package main import ( "context" "database/sql" _ "github.com/ydb-platform/ydb-go-sdk/v3" ) func main() { db, err := sql.Open("ydb", os.Getenv("YDB_CONNECTION_STRING")) if err != nil { panic(err) } defer db.Close() db.SetMaxOpenConns(100) db.SetMaxIdleConns(100) db.SetConnMaxIdleTime(time.Second) // workaround for background keep-aliving of YDB sessions ... } ``` {% endlist %} - Java {% list tabs %} - Native SDK ```java this.queryClient = QueryClient.newClient(transport) // 10 — минимальное число активных сессий, удерживаемых в пуле при очистке // 500 — максимальный размер пула сессий .sessionPoolMinSize(10) .sessionPoolMaxSize(500) .build(); ``` - JDBC При работе с JDBC, как правило, используются внешние пулы соединений, такие как [HikariCP](https://github.com/brettwooldridge/HikariCP) или [C3p0](https://github.com/swaldman/c3p0). В режиме работы по умолчанию YDB JDBC драйвер определяет количество соединений, открытых внешним пулом, и самостоятельно подстраивает размер пула сессий. Поэтому для настройки пула сессий достаточно корректно настроить `HikariCP` или `C3p0`. Пример настройки пула HikariCP в конфигурации Spring: ```properties spring.datasource.url=jdbc:ydb:grpc://localhost:2136/local spring.datasource.driver-class-name=tech.ydb.jdbc.YdbDriver spring.datasource.hikari.maximum-pool-size=100 # максимум JDBC-соединений ``` {% endlist %} - Python {% list tabs %} - Native SDK ```python import os import ydb with ydb.Driver( connection_string=os.environ["YDB_CONNECTION_STRING"], credentials=ydb.credentials_from_env_variables(), ) as driver: driver.wait(timeout=5) with ydb.QuerySessionPool(driver, size=500) as pool: # ... ``` - Native SDK (Asyncio) ```python import os import ydb import asyncio async def ydb_init(): async with ydb.aio.Driver( connection_string=os.environ["YDB_CONNECTION_STRING"], credentials=ydb.credentials_from_env_variables(), ) as driver: await driver.wait() async with ydb.aio.QuerySessionPool(driver, size=500) as pool: # ... asyncio.run(ydb_init()) ``` - SQLAlchemy Установка размера пула на данный момент не поддержана. {% endlist %} - C# В YDB C# SDK параметры пула сессий задаются через строку подключения: ```C# using Ydb.Sdk.Ado; await using var dataSource = new YdbDataSource( "Host=localhost;Port=2136;Database=/local;MaxPoolSize=500;MinPoolSize=10;SessionIdleTimeout=60"); ``` * `MaxPoolSize` — максимальный размер пула сессий (по умолчанию 100) * `MinPoolSize` — минимальное число сессий, удерживаемых в пуле (по умолчанию 0) * `SessionIdleTimeout` — время простоя сессии в секундах до её закрытия (по умолчанию 300) Для Entity Framework и linq2db используйте тот же connectionString. - JavaScript Функциональность на данный момент не поддерживается. - Rust Для `QueryClient` размер пула задаётся через [`QuerySessionPoolSettings::with_limit`](https://docs.rs/ydb/latest/ydb/struct.QuerySessionPoolSettings.html#method.with_limit) и [`with_implicit_session_pool`](https://docs.rs/ydb/latest/ydb/struct.QueryClient.html#method.with_implicit_session_pool) (или [`with_session_pool`](https://docs.rs/ydb/latest/ydb/struct.QueryClient.html#method.with_session_pool) для явных сессий): ```rust use ydb::{ClientBuilder, QuerySessionPoolSettings, YdbResult}; #[tokio::main] async fn main() -> YdbResult<()> { let client = ClientBuilder::new_from_connection_string( std::env::var("YDB_CONNECTION_STRING")?, )? .client()?; client.wait().await?; let mut qc = client .query_client() .with_implicit_session_pool( QuerySessionPoolSettings::new().with_limit(500), ); let mut row = qc.query_row("SELECT 1 AS one").await?; Ok(()) } ``` - PHP Функциональность на данный момент не поддерживается. {% endlist %}