（作者：陈玓玏）



使用clickhouse-driver包，先通过pip install clickhouse-driver安装包，再通过以下代码执行sql。

from clickhouse_driver import Client
client = Client(host='10.43.234.214', port=9000, user='clickhouse', password='c1ickh0use0perator')# 执行一个创建数据库的语句
#query = 'create table cdl'
#result = client.execute(query)# 执行一个创建表的语句
query = '''CREATE TABLE IF NOT EXISTS cdl.star
(week Int32,star Int32
)ENGINE = MergeTree()
ORDER BY week
PARTITION BY week
PRIMARY KEY week'''
result = client.execute(query)data = [{'week': 1, 'star': 1},{'week': 2, 'star': 10},{'week': 3, 'star': 100},{'week': 4, 'star': 300},{'week': 5, 'star': 500},{'week': 6, 'star': 1000}
]
#执行插入语句
query = "INSERT INTO cdl.star VALUES" + ','.join(["(%s,%s)" % (d['week'], d['star']) for d in data])
result = client.execute(query)#执行查询
query = 'select * from cdl.star limit 10'
result = client.execute(query)# 打印结果
for row in result:print(row)