clickhouse-df

请求 clickhouse集群，结果返回pandas.DataFrame/polars.DataFrame

to_polars 支持 DateTime64(0..6[, 'timezone'])，保留毫秒/微秒和显式时区， 包括 Nullable、Array 包装及空结果。当前驱动的 Python datetime 通路最高精确到微秒， 因此精度 7–9 会明确报错；需要纳秒时请在 SQL 中返回整数时间戳。

安装

pip install -U clickhouse-df

示例

import clickhouse_df

# 版本
print(clickhouse_df.__version__)

# 集群配置
config = dict(
    urls=["<host1>:<port>", "<host2>:<port>", ....],
    user="<user_name>", 
    password="xxxxxx", 
)

sql = "select * from <db_name>.<tb_name> where date='2024-10-23';"

# 例子1
with clickhouse_df.connect(**config):
    # 请求 polars 
    df_pl = clickhouse_df.to_polars(sql)
    # 请求 pandas
    df_pd = clickhouse_df.to_pandas(sql)

# 例子2
conn = clickhouse_df.connect(**config)
df_pl = clickhouse_df.to_polars(sql, conn)
df_pd = clickhouse_df.to_pandas(sql, conn)
conn.disconnect()