可以使用clickhouse-driver庫連接ClickHouse數據庫,然后使用pandas庫將查詢結果轉換為DataFrame對象。
以下是一個示例代碼:
import pandas as pd
from clickhouse_driver import Client
client = Client(host='localhost')
query = 'SELECT * FROM my_table'
result = client.execute(query)
df = pd.DataFrame(result, columns=['col1', 'col2', 'col3', ...])
其中,my_table
是要查詢的表名,col1
, col2
, col3
是表中的列名。
注意:如果數據量較大,建議使用分批次查詢的方式獲取數據,以避免內存溢出問題。