时间戳

首页 > 解决方案 > 使用 Dask 和 Psycog2 连接到远程 PostGreSql 服务器

python - 使用 Dask 和 Psycog2 连接到远程 PostGreSql 服务器

问题描述

我可以使用 pandas 和 psycopg2 连接到远程 PostgreSQL 服务器。现在，知道 pandas 读取数据库很慢，我认为使用 Dask 可以解决这个问题。因此，我决定使用 Psycopg2 和 Dask 运行，但收到​​以下错误：

import psycopg2 as pg
from sqlalchemy import create_engine
import dask.dataframe as dd
import pandas.io.sql as psql
import pandas as pd
connection = pg.connect("host='xxx.x.x.x' dbname=xxxx user=xxxx password='xxxx' port = 'xxxx'")

df = dd.read_sql_table(table='xxxx', uri='postgresql+psycopg2://user_name:password@localhost:port_number/database_name', index_col='id', npartitions=20)

df.compute()

c:\users\user_name\miniconda3\lib\site-packages\sqlalchemy\dialects\postgresql\base.py:3323: SAWarning: Skipped unsupported reflection of expression-based index uc_table_name_lower_code
  "expression-based index %s" % idx_name

上面的错误是什么意思？即使我收到错误，它也会显示表格数据框。如何在不收到错误消息的情况下运行连接？

标签： pythonpostgresqlpsycopg2dask

解决方案

推荐阅读