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

alter flexify num 1 to 2

This commit is contained in:
Leo Xu 2024-09-09 18:13:12 +08:00
parent 43c100b026
commit c65ad1287d
1 changed files with 6 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
tests/army/storage/s3/s3azure.py
View File

@ -63,8 +63,8 @@ class TDTestCase(TBase):
bucketName = "td-test" bucketName = "td-test"
updatecfgDict = { updatecfgDict = {
"supportVnodes": "1000", "supportVnodes": "1000",
's3EndPoint': 'http://192.168.1.49', 's3EndPoint': 'http://192.168.1.49,http://192.168.1.49:81',
's3AccessKey': 'FlIOwdr5HAnsMyEZ6FBwSPE5:87x1tZJll1SaK4hoiglC8zPRhDgbMeW6ufQqEt8', 's3AccessKey': 'FlIOwdr5HAnsMyEZ6FBwSPE5:87x1tZJll1SaK4hoiglC8zPRhDgbMeW6ufQqEt8,FlIOvHz0MePAf4KttYqfZM:Hve86EvB6KdvRPa5d1DG38jP6BSSSJC7IxYvSgEP',
's3BucketName': f'{bucketName}', 's3BucketName': f'{bucketName}',
's3PageCacheSize': '10240', 's3PageCacheSize': '10240',
"s3UploadDelaySec": "10", "s3UploadDelaySec": "10",
@ -161,7 +161,7 @@ class TDTestCase(TBase):
# check upload to s3 # check upload to s3
self.checkUploadToS3() self.checkUploadToS3()
def check_azure_exist(self): def checkAzureDataExist(self):
result = self.azure_class.blob_list() result = self.azure_class.blob_list()
if not self.fileName: if not self.fileName:
tdLog.exit("cannot find S3 file") tdLog.exit("cannot find S3 file")
@ -173,7 +173,7 @@ class TDTestCase(TBase):
else: else:
tdLog.exit("failed found the file %s in Azure" % self.fileName) tdLog.exit("failed found the file %s in Azure" % self.fileName)
def check_azure_not_exist(self): def checkAzureDataNotExist(self):
datafile = self.fileName.split("/")[-1].split(".")[0] datafile = self.fileName.split("/")[-1].split(".")[0]
result = self.azure_class.blob_list() result = self.azure_class.blob_list()
@ -352,7 +352,7 @@ class TDTestCase(TBase):
# do action # do action
self.doAction() self.doAction()
# check azure data exist # check azure data exist
self.check_azure_exist() self.checkAzureDataExist()
# check save agg result correct # check save agg result correct
self.checkAggCorrect() self.checkAggCorrect()
@ -365,24 +365,10 @@ class TDTestCase(TBase):
# drop stream # drop stream
self.dropStream(self.sname) self.dropStream(self.sname)
# # insert history disorder data
# self.insertHistory()
#
# # checkBasic
# self.checkBasic()
# self.checkInsertCorrect()
# self.snapshotAgg()
# self.doAction()
# self.checkAggCorrect()
# self.checkInsertCorrect(difCnt=self.childtable_count * 1499999)
# self.checkDelete()
# self.doAction()
# drop database and free s3 file # drop database and free s3 file
self.dropDb() self.dropDb()
# check azure data not exist # check azure data not exist
self.check_azure_not_exist() self.checkAzureDataNotExist()
tdLog.success(f"{__file__} successfully executed") tdLog.success(f"{__file__} successfully executed")