Merge pull request #26966 from taosdata/test/3.0/TD-31015

test:add concurrency test cases for executing the taos -k command line.

tests/system-test/0-others/taosShell.py

@@ -16,6 +16,9 @@ from util.sql import *
 from util.cases import *
 from util.dnodes import *
 
+import subprocess
+import threading
+
 def taos_command (buildPath, key, value, expectString, cfgDir, sqlString='', key1='', value1=''):
     if len(key) == 0:
         tdLog.exit("taos test key is null!")
@@ -108,7 +111,7 @@ class TDTestCase:
     updatecfgDict["fqdn"] = hostname
 
     print ("===================: ", updatecfgDict)
-
+    taos_output = []
     def init(self, conn, logSql, replicaVar=1):
         self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
@@ -116,7 +119,6 @@ class TDTestCase:
 
     def getBuildPath(self):
         selfPath = os.path.dirname(os.path.realpath(__file__))
-
         if ("community" in selfPath):
             projPath = selfPath[:selfPath.find("community")]
         else:
@@ -129,6 +131,29 @@ class TDTestCase:
                     buildPath = root[:len(root) - len("/build/bin")]
                     break
         return buildPath
+    def run_command(self, commands):
+        
+        count = 0
+        while count < 2:
+            # print(f"count: {count}")
+            value = subprocess.getoutput(f"nohup {commands} &")
+            # print(f"value: {value}")
+            self.taos_output.append(value)
+            count += 1
+            
+    def taos_thread_repeat_k(self, run_command, commands, threads_num=10, output=[]):
+        threads = []
+        taos_output = self.taos_output        
+        for id in range(threads_num):
+            #threads.append(Process(target=cloud_consumer, args=(id,)))
+            threads.append(threading.Thread(target=run_command, args=(commands,)))
+        for tr in threads:
+            tr.start()
+        for tr in threads:
+            tr.join()
+        for value in taos_output:
+            if "crash" in value:
+                tdLog.exit(f"command: {commands} crash") 
 
     def run(self):  # sourcery skip: extract-duplicate-method, remove-redundant-fstring
         tdSql.prepare()
@@ -445,6 +470,12 @@ class TDTestCase:
 
         tdSql.query('drop database %s'%newDbName)
 
+        commands = f"{buildPath}/taos -k -c {cfgPath}"
+        output = self.run_command(commands)
+        os.sys
+        self.taos_thread_repeat_k(self.run_command, commands, 100, output)
+        # os.system("python 0-others/repeat_taos_k.py")
+
     def stop(self):
         tdSql.close()
         tdLog.success(f"{__file__} successfully executed")