xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test: add csv exporting batch case

This commit is contained in:
Yaming Pei 2025-03-06 09:55:57 +08:00
parent 59ef7cd3be
commit 2c29c1a3fd
2 changed files with 27 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
tests/army/tools/benchmark/basic/exportCsv.py → tests/army/tools/benchmark/basic/csv-export.py
View File

@ -53,7 +53,7 @@ class TDTestCase(TBase):
return formatted_time return formatted_time
def calc_time_slice_partitions(self, total_start_ts, total_end_ts, ts_step, childs, ts_format, ts_interval): def calc_time_slice_partitions(self, total_start_ts, total_end_ts, ts_step, ts_format, ts_interval):
interval_days = int(ts_interval[:-1]) interval_days = int(ts_interval[:-1])
n_days_millis = interval_days * 24 * 60 * 60 * 1000 n_days_millis = interval_days * 24 * 60 * 60 * 1000
@ -82,8 +82,6 @@ class TDTestCase(TBase):
else: else:
count = delta // ts_step count = delta // ts_step
count *= childs
partitions.append({ partitions.append({
"start_ts": current_s, "start_ts": current_s,
"end_ts": current_end, "end_ts": current_end,
@ -142,7 +140,7 @@ class TDTestCase(TBase):
def check_stb_correct(self, data, db, stb): def check_stb_correct(self, data, db, stb):
filepath = data["output_path"] filepath = data["output_path"]
stbName = stb["name"] stbName = stb["name"]
childs = stb["childtable_to"] - stb["childtable_from"] child_count = stb["childtable_to"] - stb["childtable_from"]
insert_rows = stb["insert_rows"] insert_rows = stb["insert_rows"]
interlace_rows = stb["interlace_rows"] interlace_rows = stb["interlace_rows"]
csv_file_prefix = stb["csv_file_prefix"] csv_file_prefix = stb["csv_file_prefix"]
@ -154,7 +152,7 @@ class TDTestCase(TBase):
total_end_ts = total_start_ts + ts_step * insert_rows total_end_ts = total_start_ts + ts_step * insert_rows
all_rows = childs * insert_rows all_rows = child_count * insert_rows
if interlace_rows > 0: if interlace_rows > 0:
# interlace # interlace
@ -164,19 +162,34 @@ class TDTestCase(TBase):
self.check_stb_csv_correct(csv_file_name, all_rows, interlace_rows) self.check_stb_csv_correct(csv_file_name, all_rows, interlace_rows)
else: else:
# time slice # time slice
partitions = self.calc_time_slice_partitions(total_start_ts, total_end_ts, ts_step, childs, csv_ts_format, csv_ts_interval) partitions = self.calc_time_slice_partitions(total_start_ts, total_end_ts, ts_step, csv_ts_format, csv_ts_interval)
for part in partitions: for part in partitions:
csv_file_name = f"{filepath}{csv_file_prefix}_{part['start_time']}_{part['end_time']}.csv" csv_file_name = f"{filepath}{csv_file_prefix}_{part['start_time']}_{part['end_time']}.csv"
self.check_stb_csv_correct(csv_file_name, part['count'], interlace_rows) self.check_stb_csv_correct(csv_file_name, part['count'] * child_count, interlace_rows)
else: else:
# batch # batch
interlace_rows = insert_rows thread_count = stb["thread_count"]
interlace_rows = insert_rows
if not csv_ts_format: if not csv_ts_format:
# normal # normal
pass for i in range(thread_count):
csv_file_name = f"{filepath}{csv_file_prefix}_{i + 1}.csv"
if i < child_count % thread_count:
self.check_stb_csv_correct(csv_file_name, insert_rows * (child_count // thread_count + 1), interlace_rows)
else:
self.check_stb_csv_correct(csv_file_name, insert_rows * (child_count // thread_count), interlace_rows)
else: else:
# time slice # time slice
pass for i in range(thread_count):
partitions = self.calc_time_slice_partitions(total_start_ts, total_end_ts, ts_step, csv_ts_format, csv_ts_interval)
for part in partitions:
csv_file_name = f"{filepath}{csv_file_prefix}_{i + 1}_{part['start_time']}_{part['end_time']}.csv"
if i < child_count % thread_count:
slice_rows = part['count'] * (child_count // thread_count + 1)
else:
slice_rows = part['count'] * (child_count // thread_count)
self.check_stb_csv_correct(csv_file_name, slice_rows, part['count'])
# check result # check result
@ -211,7 +224,7 @@ class TDTestCase(TBase):
benchmark = etool.benchMarkFile() benchmark = etool.benchMarkFile()
# do check interlace normal # do check interlace normal
json = "tools/benchmark/basic/json/csv-interlace-normal.json" json = "tools/benchmark/basic/json/csv-export.json"
self.check_export_csv(benchmark, json) self.check_export_csv(benchmark, json)
def stop(self): def stop(self):

3
tests/parallel_test/cases.task
View File

@ -91,7 +91,8 @@
,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/default_json.py ,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/default_json.py
,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/demo.py ,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/demo.py
,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/exportCsv.py ,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/csv-export.py
# ,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/csv-import.py
,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/from-to.py ,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/from-to.py
,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/from-to-continue.py ,,y,army,./pytest.sh python3 ./test.py -f tools/benchmark/basic/from-to-continue.py