mirror of
https://github.com/hanzo-ds/connect.git
synced 2026-10-30 20:31:24 +00:00
zeekay
999d38466d
Imports read `datastore_connect`, distribution `datastore-connect`, so nothing has to import another product's name to talk to Hanzo Datastore. Cut from upstream 0.8.17 — the version this stack already ran — rather than from upstream HEAD, so it is a PURE RENAME with no behaviour change. Forking from HEAD would have dragged versions along with the name (connect alone jumped 0.8.17 -> 1.6.0, a major), which is a different and much riskier change wearing a rename's clothes. X-ClickHouse-* headers are untouched: they are wire protocol the server sends and expects, and a different token shape from the module name.
39 lines
1.1 KiB
Python
39 lines
1.1 KiB
Python
#!/usr/bin/env python3 -u
|
|
|
|
import pandas as pd
|
|
import datastore_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 = datastore_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()
|