Как написать простой запрос YQL/SQL для подключения к YDB?

Для написания простого запроса YQL/SQL для подключения к YDB, можно использовать следующий код:

```sql
SELECT * FROM my_table;
```

Для использования пула сеансов (Session Pool) в Yandex Cloud для выполнения транзакций в базе данных, необходимо правильно настроить драйвер и создать пул сеансов. После этого можно выполнить транзакцию следующим образом:

1. Получить сеанс из пула сеансов:

```python
session = session_pool.acquire()
```

2. Начать транзакцию:

```python
transaction = session.transaction()
```

3. Выполнить запросы внутри транзакции:

```python
query = "SELECT * FROM my_table"
result = transaction.execute(query)
```

4. Завершить транзакцию:

```python
transaction.commit()
```

5. Вернуть сеанс в пул сеансов после завершения использования:

```python
session_pool.release(session)
```

Следуя этим шагам, можно правильно соединить пул сеансов и сессию для выполнения запросов в YDB и избежать ошибок при создании нового сеанса.

Пример не мой, взял у коллеги. Но у меня работает. 
 
 
driver = ydb.Driver(
  endpoint="",
  database="",
  credentials=""),
)

# Wait for the driver to become active for requests.
driver.wait(fail_fast=True, timeout=5)

# Create the session pool instance to manage YDB sessions.
pool = ydb.SessionPool(driver)

def execute_query(session):
  # Create the transaction and execute query.
  return session.transaction().execute(
    'insert into dataTab (tel, SaleCount, TotalCount, stel) VALUES("9001002030", 4, 47, "8323");',
    commit_tx=True,
    settings=ydb.BaseRequestSettings().with_timeout(3).with_operation_timeout(2)
  )

result = pool.retry_operation_sync(execute_query)

Пример не мой, взял у коллеги. Но у меня работает. 
 
 
driver = ydb.Driver(
  endpoint="",
  database="",
  credentials=""),
)

# Wait for the driver to become active for requests.
driver.wait(fail_fast=True, timeout=5)

# Create the session pool instance to manage YDB sessions.
pool = ydb.SessionPool(driver)

def execute_query(session):
  # Create the transaction and execute query.
  return session.transaction().execute(
    'insert into dataTab (tel, SaleCount, TotalCount, stel) VALUES("9001002030", 4, 47, "8323");',
    commit_tx=True,
    settings=ydb.BaseRequestSettings().with_timeout(3).with_operation_timeout(2)
  )

result = pool.retry_operation_sync(execute_query)

Проблема решена! 
 У меня было так: 
 def get_pool(endpoint, database): 
 .... 
 pool = ydb.SessionPool(driver) 
 result = pool.retry_operation_sync(execute_query) 
 return result 
 
 def execute_query(session): 
 return session.transaction().execute(') 
 Даёт ошибку connection failed и всё тут. Посмотрел на код в ответе, перенёс функцию execute_query(session) внутрь главной и всё заработало! 
 Спасибо!

Проблема решена! 
 У меня было так: 
 def get_pool(endpoint, database): 
 .... 
 pool = ydb.SessionPool(driver) 
 result = pool.retry_operation_sync(execute_query) 
 return result 
 
 def execute_query(session): 
 return session.transaction().execute(') 
 Даёт ошибку connection failed и всё тут. Посмотрел на код в ответе, перенёс функцию execute_query(session) внутрь главной и всё заработало! 
 Спасибо!