Python怎么使用ClickHouse

jdbc:clickhouse://192.168.17.61:8123

jdbc:clickhouse://{host}:{port}[/{database}]?socket_timeout=600000

pip install clickhouse_driverCollecting clickhouse_driver  Downloading https://files.pythonhosted.org/packages/88/59/c570218bfca84bd0ece896c0f9ac0bf1e11543f3c01d8409f5e4f801f992/clickhouse_driver-0.2.1-cp36-cp36m-win_amd64.whl (173kB)    100% |████████████████████████████████| 174kB 27kB/sCollecting tzlocal<3.0 (from clickhouse_driver)  Downloading https://files.pythonhosted.org/packages/5d/94/d47b0fd5988e6b7059de05720a646a2930920fff247a826f61674d436ba4/tzlocal-2.1-py2.py3-none-any.whlRequirement already satisfied: pytz in d:pythonpython36libsite-packages (from clickhouse_driver) (2020.4)Installing collected packages: tzlocal, clickhouse-driverSuccessfully installed clickhouse-driver-0.2.1 tzlocal-2.1

collection = self.client.query_dataframe(self.query_sql)

# -*- coding: utf-8 -*-'''Created on 2021年3月1日@author: xiaoyw'''import pandas as pdimport jsonimport numpy as npimport datetimefrom clickhouse_driver import Client#from clickhouse_driver import connect# 基于Clickhouse数据库基础数据对象类class DB_Obj(object):    '''    192.168.17.61:9000    ebd_all_b04.card_tbl_trade_m_orc    '''    def __init__(self, db_name):        self.db_name = db_name        host='192.168.17.61' #服务器地址        port ='9000' #'8123' #端口        user='***' #用户名        password='***' #密码        database=db_name #数据库        send_receive_timeout = 25 #超时时间        self.client = Client(host=host, port=port, database=database) #, send_receive_timeout=send_receive_timeout)        #self.conn = connect(host=host, port=port, database=database) #, send_receive_timeout=send_receive_timeout)            def setPriceTable(self,df):        self.pricetable = df    def get_trade(self,df_trade,filename):                  print('Trade join price!')        df_trade = pd.merge(left=df_trade,right=self.pricetable[['occurday','DIM_DATE','END_DATE','V_0','V_92','V_95','ZDE_0','ZDE_92',                              'ZDE_95']],how="left",on=['occurday'])        df_trade.to_csv(filename,mode='a',encoding='utf-8',index=False)    def get_datas(self,query_sql):                  n = 0 # 累计处理卡客户数据        k = 0 # 取每次DataFrame数据量        batch = 100000 #100000 # 分批次处理        i = 0 # 文件标题顺序累加        flag=True # 数据处理解释标志        filename = 'card_trade_all_{}.csv'        while flag:            self.query_sql = query_sql.format(n, n+batch)             print('query started')            collection = self.client.query_dataframe(self.query_sql)            print('return query result')            df_trade = collection #pd.DataFrame(collection)                        i=i+1            k = len(df_trade)             if k > 0:                self.get_trade(df_trade, filename.format(i))                        n = n + batch            if k == 0:                flag=False                    print('Completed ' + str(k) + 'trade details!')            print('Usercard count ' + str(n) )                           return n                # 价格变动数据集class Price_Table(object):    def __init__(self, cityname, startdate):        self.cityname = cityname        self.startdate = startdate        self.filename = 'price20210531.csv'            def get_price(self):        df_price = pd.read_csv(self.filename)        ......            self.price_table=self.price_table.append(data_dict, ignore_index=True)                        print('generate price table!')   class CardTradeDB(object):    def __init__(self,db_obj):         self.db_obj = db_obj            def insertDatasByCSV(self,filename):        # 存在数据混合类型        df = pd.read_csv(filename,low_memory=False)            # 获取交易记录        def getTradeDatasByID(self,ID_list=None):        # 字符串过长，需要使用'''        query_sql = '''select C.carduser_id,C.org_id,C.cardasn,C.occurday as         		......                limit {},{})                group by C.carduser_id,C.org_id,C.cardasn,C.occurday                order by C.carduser_id,C.occurday'''                        n = self.db_obj.get_datas(query_sql)                return n                    if __name__ == '__main__':    PTable = Price_Table('湖北','2015-12-01')       PTable.get_price()          db_obj = DB_Obj('ebd_all_b04')    db_obj.setPriceTable(PTable.price_table)    CTD = CardTradeDB(db_obj)    df = CTD.getTradeDatasByID()

def info_del2(i):    client = click_client(host='地址', port=端口, user='用户名', password='密码',                          database='数据库')    sql_detail='alter table SS_GOODS_ORDER_ALL delete where order_id='+str(i)+';'    try:        client.execute(sql_detail)    except Exception as e:        print(e,'删除商品数据失败')