python接続clickhouseの使用方法
836 ワード
ぜんせん
clickhouseは現在、分散型ストレージの成熟したソリューションとしてpython開発でclickhouseの接続スキームをよく使用しています.以下に、clickhouseを簡単に接続する方法を示します.
本文
clickhouseは現在、分散型ストレージの成熟したソリューションとしてpython開発でclickhouseの接続スキームをよく使用しています.以下に、clickhouseを簡単に接続する方法を示します.
本文
from clickhouse_driver import Client as click_client
def click_server(ip: str, user: str, pwd: str, port='8123', databases='',query=''):
"""
clickhouse
:param ip: clickhouseIP
:param user:
:param pwd:
:param port:
:param databases:
:param query:
:return: list
"""
chs_host = ip
chs_user = user
chs_pwd = pwd
chs_port = port
chs_database = databases
client = click_client(host=chs_host, port=chs_port, user=chs_user, password=chs_pwd, database=chs_database, send_receive_timeout=5)
ans = client.execute(query=query, with_column_types=True)
return ans