Чтение SQL-таблиц с MS SQL Server с помощью Connectorx на Python ⇐ Python

[Anonymous]

Я пытаюсь прочитать таблицы sql из MS SQL Server 2014 с помощью Connectorx в Python Polars в Jupyter Notebook.
Мой код:

Код: Выделить всё

#importing libraries

import pyarrow
from connectorx import read_sql
import polars as pl
import os
import gensim
import spacy
import csv
import numpy as np
import pandas as pd

#loading spacy language model

nlp = spacy.load("de_core_news_lg")

#reading sql tables and creating connection

connection = "mssql://username:password@PAMUK5AM100:1433/db"
user = "SELECT * FROM v_Text"
questions = "SELECT * FROM v_Questions"

#reading sql tables and creating dataframes

user_df = pl.read_sql(user, connection)

questions_df = pl.read_sql(questions, connection)

После запуска я получаю следующую ошибку:

Код: Выделить всё

---------------------------------------------------------------------------
RuntimeError                              Traceback (most recent call last)
Input In [24], in ()
1 #reading sql tables and creating dataframes
----> 3 user_df = pl.read_sql(user, connection)
5 questions_df = pl.read_sql(questions, connection)

File ~\Anaconda3\lib\site-packages\polars\io.py:1105, in read_sql(sql, connection_uri, partition_on, partition_range, partition_num, protocol)
1100 except ImportError:
1101     raise ImportError(
1102         "connectorx is not installed. Please run `pip install connectorx>=0.3.1`."
1103     ) from None
-> 1105 tbl = cx.read_sql(
1106     conn=connection_uri,
1107     query=sql,
1108     return_type="arrow2",
1109     partition_on=partition_on,
1110     partition_range=partition_range,
1111     partition_num=partition_num,
1112     protocol=protocol,
1113 )
1115 return cast(DataFrame, from_arrow(tbl))

File ~\Anaconda3\lib\site-packages\connectorx\__init__.py:257, in read_sql(conn, query, return_type, protocol, partition_on, partition_range, partition_num, index_col)
254 except ModuleNotFoundError:
255     raise ValueError("You need to install pyarrow first")
--> 257 result = _read_sql(
258     conn,
259     "arrow" if return_type in {"arrow", "polars"} else "arrow2",
260     queries=queries,
261     protocol=protocol,
262     partition_query=partition_query,
263 )
264 df = reconstruct_arrow(result)
265 if return_type in {"polars", "polars2"}:

RuntimeError: Timed out in bb8

Что я делаю не так? Я уже установил Pyarrow и Connectorx, но все равно получаю эту ошибку. Пожалуйста, помогите.
Спасибо.

Подробнее здесь: https://stackoverflow.com/questions/752 ... -in-python