thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

add missing method

Browse Source
This commit is contained in:
Nikita Taranov 2024-03-18 20:04:56 +00:00
parent 0b2c274132
commit 726db7361f
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/ci/clickhouse_helper.py
View File

@ -109,6 +109,16 @@ class ClickHouseHelper:
def _insert_json_str_info(self, db, table, json_str):
self.insert_json_str(self.url, self.auth, db, table, json_str)
def insert_json_into(self, db, table, json_str, safe=True):
try:
self._insert_json_str_info(db, table, json_str)
except InsertException as e:
logging.error(
"Exception happened during inserting data into clickhouse: %s", e
)
if not safe:
raise
def insert_event_into(self, db, table, event, safe=True):
event_str = json.dumps(event)
try: