Spaces:

petermutwiri
/

Computations

Paused

shaliz-kong

Initial commit: self-hosted Redis analytics engine

98cacb0 11 months ago

231 Bytes

from datetime import datetime
def ingest_dict(org_id: str, payload: dict):
    conn = get_conn(org_id)
    ensure_raw_table(conn)
    conn.execute("INSERT INTO raw_rows(row_data) VALUES (?)", [json.dumps(payload)])
    conn.close()

	from datetime import datetime
	def ingest_dict(org_id: str, payload: dict):
	conn = get_conn(org_id)
	ensure_raw_table(conn)
	conn.execute("INSERT INTO raw_rows(row_data) VALUES (?)", [json.dumps(payload)])
	conn.close()