modify insert ts contiune
This commit is contained in:
parent
091da20ab8
commit
9a8660dd4e
|
@ -163,16 +163,18 @@ class AutoGen:
|
||||||
values = ""
|
values = ""
|
||||||
|
|
||||||
tdLog.info(f" insert child data {child_name} finished, insert rows={cnt}")
|
tdLog.info(f" insert child data {child_name} finished, insert rows={cnt}")
|
||||||
self.ts = ts
|
return ts
|
||||||
|
|
||||||
def insert_data(self, cnt, bContinue=False):
|
def insert_data(self, cnt, bContinue=False):
|
||||||
if not bContinue:
|
if not bContinue:
|
||||||
self.ts = 1600000000000
|
self.ts = 1600000000000
|
||||||
|
|
||||||
|
currTs = 1600000000000
|
||||||
for i in range(self.child_cnt):
|
for i in range(self.child_cnt):
|
||||||
name = f"{self.child_name}{i}"
|
name = f"{self.child_name}{i}"
|
||||||
self.insert_data_child(name, cnt, self.batch_size, 1)
|
currTs = self.insert_data_child(name, cnt, self.batch_size, 1)
|
||||||
|
|
||||||
|
self.ts = currTs
|
||||||
tdLog.info(f" insert data ok, child table={self.child_cnt} insert rows={cnt}")
|
tdLog.info(f" insert data ok, child table={self.child_cnt} insert rows={cnt}")
|
||||||
|
|
||||||
# insert same timestamp to all childs
|
# insert same timestamp to all childs
|
||||||
|
|
Loading…
Reference in New Issue