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.
60 lines
2.0 KiB
Python
60 lines
2.0 KiB
Python
#!/usr/bin/env python3 -u
|
|
|
|
from datetime import datetime, timedelta
|
|
|
|
from datastore_connect.driver.binding import finalize_query
|
|
|
|
select_template = """
|
|
SELECT
|
|
formatDateTime(started_at, '%%m/%%d/%%Y', %(time_zone)s) AS date,
|
|
formatDateTime(started_at, '%%I:%%M:%%S %%p', %(time_zone)s) AS time,
|
|
format('{}path/link?name={}&dev_type={}', %(web_url)s, label, device_type) AS url,
|
|
device_name,
|
|
description
|
|
FROM sessions
|
|
"""
|
|
|
|
|
|
def build_device_query(time_zone: str,
|
|
web_url: str,
|
|
client: str,
|
|
company_id: str = '',
|
|
device_id: str = '',
|
|
updated: bool = False,
|
|
start_time: datetime = None,
|
|
end_time: datetime = None):
|
|
params = {'time_zone': time_zone,
|
|
'web_url': web_url,
|
|
'client': client
|
|
}
|
|
where_template = ' WHERE client = %(client)s'
|
|
if company_id:
|
|
where_template += ' AND company_id = %(company_id)s'
|
|
params['company_id'] = company_id
|
|
if device_id:
|
|
where_template += ' AND dev_type = %(device_id)s'
|
|
params['device_id'] = device_id
|
|
if updated:
|
|
where_template += ' AND updated = true'
|
|
if start_time and end_time:
|
|
where_template += ' AND started_at BETWEEN %(start_time)s AND %(end_time)s'
|
|
params['start_time'] = start_time
|
|
params['end_time'] = end_time
|
|
full_query = select_template + where_template + ' ORDER BY started_at ASC'
|
|
return finalize_query(full_query, params)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
start = datetime.now()
|
|
end = start + timedelta(hours=1, minutes=20)
|
|
print(build_device_query('UTC',
|
|
'https://example.com',
|
|
|
|
client='Client_0',
|
|
company_id='Company_1',
|
|
device_id='DEVICE_77',
|
|
start_time=start,
|
|
end_time=end
|
|
)
|
|
)
|