Pandas连接Clickhouse

我这里介绍两种方法：

1. 使用Pandas的read_sql方法通过sqlalchemy连接Clickhouse，需要安装clickhouse-sqlalchemy

2. 使用pandahouse直接读取，返回DataFrame

推荐使用第一种方式，因为与我们平时连接数据库方式一致，无缝衔接，而且clickhouse-sqlalchemy一直在维护，pandahouse已经很久没更新了。

clickhouse-sqlalchemy

pip install clickhouse-sqlalchemy

from sqlalchemy import create_engine
import pandas as pd
click_url = f'clickhouse+http://admin:paswd@localhost:8123/pro'
engine = create_engine(click_url)

fin_sql = '''
select count(code) from finished
'''

pd.read_sql(fin_sql,con=engine)

pandahouse

pip install pandahouse

from pandahouse import read_clickhouse

connection = dict(database='pro',
                  host='localhost:8123',
                  user='admin',
                  password='paswd')

df = read_clickhouse(fin_sql,connection=connection)