mirror of
https://github.com/hanzo-ds/connect.git
synced 2026-10-30 20:31:24 +00:00
Joe SpadolaandGitHub
55dcd7db4c
* migrate from pylint to ruff * ruff format/lint switch over * add formatting commit * update changelog
43 lines
1.1 KiB
Python
43 lines
1.1 KiB
Python
#!/usr/bin/env python3 -u
|
|
|
|
import pandas as pd
|
|
|
|
import clickhouse_connect
|
|
|
|
create_table_sql = """
|
|
CREATE TABLE pandas_example
|
|
(
|
|
`timeseries` DateTime('UTC'),
|
|
`int_value` Int32,
|
|
`str_value` String,
|
|
`float_value` Float64
|
|
)
|
|
ENGINE = MergeTree
|
|
ORDER BY timeseries
|
|
"""
|
|
|
|
|
|
def write_pandas_df():
|
|
client = clickhouse_connect.get_client(host="localhost", port="8123", user="default", password="")
|
|
client.command("DROP TABLE IF EXISTS pandas_example")
|
|
client.command(create_table_sql)
|
|
df = pd.DataFrame(
|
|
{
|
|
"timeseries": ["04/03/2022 10:00:11", "05/03/2022 11:15:44", "06/03/2022 17:14:00"],
|
|
"int_value": [16, 19, 11],
|
|
"str_value": ["String One", "String Two", "A Third String"],
|
|
"float_value": [2344.288, -73002.4444, 3.14159],
|
|
}
|
|
)
|
|
df["timeseries"] = pd.to_datetime(df["timeseries"])
|
|
client.insert_df("pandas_example", df)
|
|
result_df = client.query_df("SELECT * FROM pandas_example")
|
|
print()
|
|
print(result_df.dtypes)
|
|
print()
|
|
print(result_df)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
write_pandas_df()
|