feat auto update sdk

Author: liyan.90210

Changelog

@@ -1,5 +1,8 @@
 ### Change log
 
+2026-07-16 Bumped to version v1.0.226
+- Updated apis for imagex/tls
+
 2026-07-09 Bumped to version v1.0.225
 - Updated apis for vod
 

volcengine/__init__.py

@@ -1,2 +1,2 @@
 # coding:utf-8
-VERSION='v1.0.225'
+VERSION='v1.0.226'

volcengine/imagex/ImageXService.py

@@ -11,7 +11,7 @@
 from volcengine.util.Util import *
 from volcengine.Policy import *
 from volcengine.imagex.ImageXConfig import *
-from retry import retry
+from tenacity import retry, stop_after_attempt, wait_exponential
 
 
 class Uploader:
@@ -75,7 +75,7 @@ def async_upload(self):
                     'Error': e,
                 })
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def upload_by_host(self, store_info, img_data):
         url = 'https://{}/{}'.format(self.host, store_info['StoreUri'])
         check_sum = crc32(img_data) & 0xFFFFFFFF
@@ -104,7 +104,7 @@ def chunk_upload(self, store_info, f, size, is_large_file):
         parts.append(part)
         return self.upload_merge_part(store_info, upload_id, parts, is_large_file)
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def init_upload_part(self, store_info, is_large_file):
         url = 'https://{}/{}?uploads'.format(self.host, store_info['StoreUri'])
         headers = {'Authorization': store_info['Auth']}
@@ -118,7 +118,7 @@ def init_upload_part(self, store_info, is_large_file):
             raise Exception("init upload error")
         return resp['payload']['uploadID']
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def upload_part(self, store_info, upload_id, part_number, data, is_large_file):
         url = 'https://{}/{}?partNumber={}&uploadID={}'.format(self.host, store_info['StoreUri'], part_number,
                                                                upload_id)
@@ -146,7 +146,7 @@ def generate_merge_body(check_sum_list):
         comma = ','
         return comma.join(s)
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def upload_merge_part(self, store_info, upload_id, check_sum_list, is_large_file):
         url = 'https://{}/{}?uploadID={}'.format(self.host, store_info['StoreUri'], upload_id)
         data = self.generate_merge_body(check_sum_list)

volcengine/imagex/v2/upload.py

@@ -7,7 +7,7 @@
 from volcengine.Policy import *
 from volcengine.imagex.v2.const import *
 
-from retry import retry
+from tenacity import retry, stop_after_attempt, wait_exponential
 from urllib.parse import quote
 
 try:
@@ -95,7 +95,7 @@ def async_upload(self):
                     }
                 )
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def upload_by_host(self, store_info, img_data, param=None):
         if param is None:
             param = {}
@@ -136,7 +136,7 @@ def chunk_upload(self, store_info, f, size, is_large_file, param=None):
         parts.append(part)
         return self.upload_merge_part(store_info, upload_id, parts, is_large_file, param)
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def init_upload_part(self, store_info, is_large_file, param=None):
         if param is None:
             param = {}
@@ -156,7 +156,7 @@ def init_upload_part(self, store_info, is_large_file, param=None):
             raise Exception("init upload error")
         return resp["payload"]["uploadID"]
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def upload_part(self, store_info, upload_id, part_number, data, is_large_file):
         url = "https://{}/{}?partNumber={}&uploadID={}".format(
             self.host, quote(store_info["StoreUri"]), part_number, upload_id
@@ -185,7 +185,7 @@ def generate_merge_body(check_sum_list):
         comma = ","
         return comma.join(s)
 
-    @retry(tries=3, delay=1, backoff=2)
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=1), reraise=True)
     def upload_merge_part(self, store_info, upload_id, check_sum_list, is_large_file, param=None):
         if param is None:
             param = {}

volcengine/tls/const.py

@@ -560,8 +560,12 @@
 QUERY_PARAMS = "QueryParams"
 SCHEDULE_SQL_TASK_INFO = "ScheduleSqlTaskInfo"
 SHIPPER_TO_TOS_INFO = "ShipperToTosInfo"
+SHIPPER_TO_AGENT_LOOP_INFO = "ShipperToAgentLoopInfo"
+ETL_TASK_INFO = "ETLTaskInfo"
 LOG_BACK_FLOW_TASKS = "LogBackFlowTasks"
 RELA_TASKS_INFO = "RelaTasksInfo"
+LOG_BACK_FLOW_ETL_TASK_ID = "ETLTaskId"
+ETL_TASK_NAME = "ETLTaskName"
 SCHEDULE_SQL_TASK_ID = "ScheduleSQLTaskId"
 SCHEDULE_SQL_TASK_NAME = "ScheduleSQLTaskName"
 SOURCE_TYPE = "SourceType"
@@ -583,6 +587,28 @@
 PROCESS_START_TIME = "ProcessStartTime"
 PROCESS_END_TIME = "ProcessEndTime"
 PROCESS_SQL_DELAY = "ProcessSqlDelay"
+EVALUATION_SET_SHIPPER_INFO = "EvaluationSetShipperInfo"
+WORKSPACE_ID = "WorkspaceId"
+EVALUATION_SET_ID = "EvaluationSetId"
+EVALUATION_SET_NAME = "EvaluationSetName"
+EVALUATION_SET_DESCRIPTION = "EvaluationSetDescription"
+BIZ_CATEGORY = "BizCategory"
+EVALUATION_SET_SCHEMA = "EvaluationSetSchema"
+FIELD_SCHEMAS = "FieldSchemas"
+FIELD_MAPPINGS = "FieldMappings"
+ITEM_KEY_FIELD = "ItemKeyField"
+BATCH_SIZE = "BatchSize"
+SKIP_INVALID_ITEMS = "SkipInvalidItems"
+ALLOW_PARTIAL_ADD = "AllowPartialAdd"
+
+LOG_BACK_FLOW_TASK_STATUS_DONE = "DONE"
+LOG_BACK_FLOW_TASK_STATUS_CREATING = "CREATING"
+LOG_BACK_FLOW_TASK_STATUS_FINISHED = "FINISHED"
+LOG_BACK_FLOW_TASK_STATUS_DELETING = "DELETING"
+LOG_BACK_FLOW_TASK_STATUS_CREATE_FAILED = "CREATEFAILED"
+LOG_BACK_FLOW_TASK_STATUS_RUN_FAILED = "RUNFAILED"
+PARQUET_INFO = "ParquetInfo"
+TRANS_TYPE = "TransType"
 PROCESS_TIME_WINDOW = "ProcessTimeWindow"
 CREATE_TIME_STAMP = "CreateTimeStamp"
 MODIFY_TIME_STAMP = "ModifyTimeStamp"