From d3ea935fed1c360c1bffa17daf0e4c1b036a5a1b Mon Sep 17 00:00:00 2001 From: yeqiang02 Date: Thu, 11 Jul 2024 15:03:55 +0800 Subject: [PATCH 1/2] =?UTF-8?q?OMSEC-112581=20=E3=80=90=E5=90=8E=E7=AB=AF?= =?UTF-8?q?=E3=80=91=E3=80=90=E5=AE=98=E7=BD=91demo=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E3=80=91=E6=89=80=E6=9C=89=E8=AF=AD=E8=A8=80=E7=9A=84=E7=A4=BA?= =?UTF-8?q?=E4=BE=8B=E4=BB=A3=E7=A0=81=E5=A2=9E=E5=8A=A0=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E6=B1=A0=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 【后端】【官网demo优化】所有语言的示例代码增加连接池配置 --- aigc/aigc_stream_callback.py | 19 +++++++++++++------ aigc/aigc_stream_push.py | 19 +++++++++++++------ audio/audio_callback.py | 19 +++++++++++++------ audio/audio_check.py | 19 +++++++++++++------ audio/audio_query.py | 19 +++++++++++++------ audio/audio_submit.py | 19 +++++++++++++------ audio/liveaudio_callback.py | 19 +++++++++++++------ audio/liveaudio_check.py | 19 +++++++++++++------ audio/liveaudio_feedback.py | 19 +++++++++++++------ audio/liveaudio_queryextra.py | 19 +++++++++++++------ audio/liveaudio_querymonitor.py | 19 +++++++++++++------ audio/liveaudio_querytask.py | 19 +++++++++++++------ crawler/crawler_callback.py | 19 +++++++++++++------ crawler/crawler_job_submit.py | 19 +++++++++++++------ crawler/crawler_submit.py | 19 +++++++++++++------ digital/digital_callback.py | 19 +++++++++++++------ digital/digital_query.py | 17 ++++++++++++----- digital/digital_submit.py | 19 +++++++++++++------ filesolution/filesolution_callback.py | 19 +++++++++++++------ filesolution/filesolution_query.py | 19 +++++++++++++------ filesolution/filesolution_submit.py | 19 +++++++++++++------ image/image_asynccheck.py | 19 +++++++++++++------ image/image_callback.py | 19 +++++++++++++------ image/image_check.py | 19 +++++++++++++------ image/image_query.py | 19 +++++++++++++------ image/image_submit.py | 19 +++++++++++++------ image/imagelist_delete.py | 19 +++++++++++++------ image/imagelist_query.py | 19 +++++++++++++------ image/imagelist_submit.py | 19 +++++++++++++------ image/imagelist_update.py | 19 +++++++++++++------ keyword/keyword_delete.py | 19 +++++++++++++------ keyword/keyword_query.py | 19 +++++++++++++------ keyword/keyword_submit.py | 19 +++++++++++++------ list/list_delete.py | 19 +++++++++++++------ list/list_query.py | 19 +++++++++++++------ list/list_submit.py | 19 +++++++++++++------ list/list_update.py | 19 +++++++++++++------ .../livevideosolution_callback.py | 19 +++++++++++++------ .../livevideosolution_feedback.py | 19 +++++++++++++------ .../livevideosolution_queryaudio.py | 19 +++++++++++++------ .../livevideosolution_queryimage.py | 19 +++++++++++++------ .../livevideosolution_querymonitor.py | 19 +++++++++++++------ livevideosolution/livevideosolution_submit.py | 19 +++++++++++++------ mediasolution/mediasolution_callback.py | 19 +++++++++++++------ mediasolution/mediasolution_query.py | 17 ++++++++++++----- mediasolution/mediasolution_submit.py | 19 +++++++++++++------ report/report_callback.py | 19 +++++++++++++------ report/report_query.py | 17 ++++++++++++----- report/report_submit.py | 19 +++++++++++++------ text/text_batch_check.py | 19 +++++++++++++------ text/text_callback.py | 17 ++++++++++++----- text/text_check.py | 19 +++++++++++++------ text/text_query.py | 17 ++++++++++++----- text/text_submit.py | 19 +++++++++++++------ video/liveimage_query.py | 17 ++++++++++++----- video/livevideo_callback.py | 19 +++++++++++++------ video/livevideo_feedback.py | 19 +++++++++++++------ video/livevideo_query.py | 17 ++++++++++++----- video/livevideo_submit.py | 19 +++++++++++++------ video/livewall_callback.py | 19 +++++++++++++------ video/livewall_querymonitor.py | 19 +++++++++++++------ video/livewall_submit.py | 19 +++++++++++++------ video/video_callback.py | 17 ++++++++++++----- video/video_query.py | 17 ++++++++++++----- video/video_submit.py | 19 +++++++++++++------ video/videoimage_query.py | 17 ++++++++++++----- videosolution/videosolution_callback.py | 19 +++++++++++++------ videosolution/videosolution_query.py | 19 +++++++++++++------ videosolution/videosolution_submit.py | 19 +++++++++++++------ 69 files changed, 887 insertions(+), 404 deletions(-) diff --git a/aigc/aigc_stream_callback.py b/aigc/aigc_stream_callback.py index db89aac..b2ffde1 100644 --- a/aigc/aigc_stream_callback.py +++ b/aigc/aigc_stream_callback.py @@ -14,8 +14,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -34,6 +34,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -64,10 +65,16 @@ def check(self): params["signatureMethod"] = "MD5" params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/aigc/aigc_stream_push.py b/aigc/aigc_stream_push.py index 9413f07..2c84932 100644 --- a/aigc/aigc_stream_push.py +++ b/aigc/aigc_stream_push.py @@ -14,8 +14,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -34,6 +34,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/audio_callback.py b/audio/audio_callback.py index f459352..f2026fe 100644 --- a/audio/audio_callback.py +++ b/audio/audio_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -68,10 +69,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/audio_check.py b/audio/audio_check.py index b7cad57..852be41 100644 --- a/audio/audio_check.py +++ b/audio/audio_check.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/audio_query.py b/audio/audio_query.py index e1afe5d..a93bad7 100644 --- a/audio/audio_query.py +++ b/audio/audio_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/audio_submit.py b/audio/audio_submit.py index 4a6f860..65f4b1d 100644 --- a/audio/audio_submit.py +++ b/audio/audio_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/liveaudio_callback.py b/audio/liveaudio_callback.py index a985a21..cf12cc9 100644 --- a/audio/liveaudio_callback.py +++ b/audio/liveaudio_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -68,10 +69,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/liveaudio_check.py b/audio/liveaudio_check.py index 54907f8..6d8a833 100644 --- a/audio/liveaudio_check.py +++ b/audio/liveaudio_check.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/liveaudio_feedback.py b/audio/liveaudio_feedback.py index a7db60c..8e4db10 100644 --- a/audio/liveaudio_feedback.py +++ b/audio/liveaudio_feedback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -67,10 +68,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/liveaudio_queryextra.py b/audio/liveaudio_queryextra.py index f9c0f72..ad8e6d5 100644 --- a/audio/liveaudio_queryextra.py +++ b/audio/liveaudio_queryextra.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -67,10 +68,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/liveaudio_querymonitor.py b/audio/liveaudio_querymonitor.py index 70b9b5a..398b1b5 100644 --- a/audio/liveaudio_querymonitor.py +++ b/audio/liveaudio_querymonitor.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -67,10 +68,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/audio/liveaudio_querytask.py b/audio/liveaudio_querytask.py index 1d1d535..4f5f4f3 100644 --- a/audio/liveaudio_querytask.py +++ b/audio/liveaudio_querytask.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -67,10 +68,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/crawler/crawler_callback.py b/crawler/crawler_callback.py index 21626ad..53baac6 100644 --- a/crawler/crawler_callback.py +++ b/crawler/crawler_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/crawler/crawler_job_submit.py b/crawler/crawler_job_submit.py index 8f345d5..a028470 100644 --- a/crawler/crawler_job_submit.py +++ b/crawler/crawler_job_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/crawler/crawler_submit.py b/crawler/crawler_submit.py index 6997e64..13a5765 100644 --- a/crawler/crawler_submit.py +++ b/crawler/crawler_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/digital/digital_callback.py b/digital/digital_callback.py index 450f67d..2ec650c 100644 --- a/digital/digital_callback.py +++ b/digital/digital_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/digital/digital_query.py b/digital/digital_query.py index 38810bb..81e4372 100644 --- a/digital/digital_query.py +++ b/digital/digital_query.py @@ -14,8 +14,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -36,6 +36,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,9 +70,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/digital/digital_submit.py b/digital/digital_submit.py index a1b356e..b951e81 100644 --- a/digital/digital_submit.py +++ b/digital/digital_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/filesolution/filesolution_callback.py b/filesolution/filesolution_callback.py index 7517459..92c1d84 100644 --- a/filesolution/filesolution_callback.py +++ b/filesolution/filesolution_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/filesolution/filesolution_query.py b/filesolution/filesolution_query.py index 9b19a99..1237de5 100644 --- a/filesolution/filesolution_query.py +++ b/filesolution/filesolution_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -64,10 +65,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/filesolution/filesolution_submit.py b/filesolution/filesolution_submit.py index 5116dae..d9db066 100644 --- a/filesolution/filesolution_submit.py +++ b/filesolution/filesolution_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/image_asynccheck.py b/image/image_asynccheck.py index 0bbcf7b..c6226f3 100644 --- a/image/image_asynccheck.py +++ b/image/image_asynccheck.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/image_callback.py b/image/image_callback.py index a968b98..58d0f04 100644 --- a/image/image_callback.py +++ b/image/image_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -68,10 +69,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/image_check.py b/image/image_check.py index 2045a60..120cf74 100644 --- a/image/image_check.py +++ b/image/image_check.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/image_query.py b/image/image_query.py index 24a01fc..35feb87 100644 --- a/image/image_query.py +++ b/image/image_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/image_submit.py b/image/image_submit.py index 07e8f4f..bd09305 100644 --- a/image/image_submit.py +++ b/image/image_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/imagelist_delete.py b/image/imagelist_delete.py index 9949a1c..5b5dbc5 100644 --- a/image/imagelist_delete.py +++ b/image/imagelist_delete.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/imagelist_query.py b/image/imagelist_query.py index 88d483d..53c124a 100644 --- a/image/imagelist_query.py +++ b/image/imagelist_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/imagelist_submit.py b/image/imagelist_submit.py index d42defa..a26cea5 100644 --- a/image/imagelist_submit.py +++ b/image/imagelist_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/image/imagelist_update.py b/image/imagelist_update.py index 4d8c605..383943a 100644 --- a/image/imagelist_update.py +++ b/image/imagelist_update.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/keyword/keyword_delete.py b/keyword/keyword_delete.py index f812b20..9c5d8a1 100644 --- a/keyword/keyword_delete.py +++ b/keyword/keyword_delete.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/keyword/keyword_query.py b/keyword/keyword_query.py index 1e32465..a1c0f42 100644 --- a/keyword/keyword_query.py +++ b/keyword/keyword_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/keyword/keyword_submit.py b/keyword/keyword_submit.py index d469392..cc5eac9 100644 --- a/keyword/keyword_submit.py +++ b/keyword/keyword_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/list/list_delete.py b/list/list_delete.py index f76d171..f05dbe9 100644 --- a/list/list_delete.py +++ b/list/list_delete.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/list/list_query.py b/list/list_query.py index 94f9830..d258e22 100644 --- a/list/list_query.py +++ b/list/list_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/list/list_submit.py b/list/list_submit.py index b56e102..405994d 100644 --- a/list/list_submit.py +++ b/list/list_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/list/list_update.py b/list/list_update.py index 59fead4..86431f2 100644 --- a/list/list_update.py +++ b/list/list_update.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/livevideosolution/livevideosolution_callback.py b/livevideosolution/livevideosolution_callback.py index b41b4b6..7859008 100644 --- a/livevideosolution/livevideosolution_callback.py +++ b/livevideosolution/livevideosolution_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/livevideosolution/livevideosolution_feedback.py b/livevideosolution/livevideosolution_feedback.py index d2649d8..fd0ee72 100644 --- a/livevideosolution/livevideosolution_feedback.py +++ b/livevideosolution/livevideosolution_feedback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/livevideosolution/livevideosolution_queryaudio.py b/livevideosolution/livevideosolution_queryaudio.py index 6cf421b..baf6411 100644 --- a/livevideosolution/livevideosolution_queryaudio.py +++ b/livevideosolution/livevideosolution_queryaudio.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/livevideosolution/livevideosolution_queryimage.py b/livevideosolution/livevideosolution_queryimage.py index 82b3e11..e3fac23 100644 --- a/livevideosolution/livevideosolution_queryimage.py +++ b/livevideosolution/livevideosolution_queryimage.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/livevideosolution/livevideosolution_querymonitor.py b/livevideosolution/livevideosolution_querymonitor.py index 5a7e8f1..21ce3ce 100644 --- a/livevideosolution/livevideosolution_querymonitor.py +++ b/livevideosolution/livevideosolution_querymonitor.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/livevideosolution/livevideosolution_submit.py b/livevideosolution/livevideosolution_submit.py index e4a3a82..8ed3a15 100644 --- a/livevideosolution/livevideosolution_submit.py +++ b/livevideosolution/livevideosolution_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/mediasolution/mediasolution_callback.py b/mediasolution/mediasolution_callback.py index 2905cc7..6672995 100644 --- a/mediasolution/mediasolution_callback.py +++ b/mediasolution/mediasolution_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/mediasolution/mediasolution_query.py b/mediasolution/mediasolution_query.py index baead57..e54c27b 100644 --- a/mediasolution/mediasolution_query.py +++ b/mediasolution/mediasolution_query.py @@ -14,8 +14,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -36,6 +36,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,9 +70,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/mediasolution/mediasolution_submit.py b/mediasolution/mediasolution_submit.py index 77d715f..2a7376a 100644 --- a/mediasolution/mediasolution_submit.py +++ b/mediasolution/mediasolution_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/report/report_callback.py b/report/report_callback.py index 7e6133d..7daf457 100644 --- a/report/report_callback.py +++ b/report/report_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/report/report_query.py b/report/report_query.py index 2cd88ba..c3455c6 100644 --- a/report/report_query.py +++ b/report/report_query.py @@ -14,8 +14,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -36,6 +36,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,9 +70,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/report/report_submit.py b/report/report_submit.py index aa7d043..80bd6d7 100644 --- a/report/report_submit.py +++ b/report/report_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/text/text_batch_check.py b/text/text_batch_check.py index 9708ade..8a6890d 100644 --- a/text/text_batch_check.py +++ b/text/text_batch_check.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/text/text_callback.py b/text/text_callback.py index 2880fa3..d0f1bcd 100644 --- a/text/text_callback.py +++ b/text/text_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,9 +70,15 @@ def check(self): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/text/text_check.py b/text/text_check.py index e6bda93..3fe6722 100644 --- a/text/text_check.py +++ b/text/text_check.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/text/text_query.py b/text/text_query.py index c2b7631..83ad876 100644 --- a/text/text_query.py +++ b/text/text_query.py @@ -14,8 +14,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -36,6 +36,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,9 +70,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/text/text_submit.py b/text/text_submit.py index 163a3b9..9040d04 100644 --- a/text/text_submit.py +++ b/text/text_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/liveimage_query.py b/video/liveimage_query.py index dd32cb1..3957237 100644 --- a/video/liveimage_query.py +++ b/video/liveimage_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -70,9 +71,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/livevideo_callback.py b/video/livevideo_callback.py index 4056222..46e7a60 100644 --- a/video/livevideo_callback.py +++ b/video/livevideo_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -68,10 +69,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/livevideo_feedback.py b/video/livevideo_feedback.py index cf44b2e..0a95269 100644 --- a/video/livevideo_feedback.py +++ b/video/livevideo_feedback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -36,6 +36,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -68,10 +69,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/livevideo_query.py b/video/livevideo_query.py index d32f507..5089be1 100644 --- a/video/livevideo_query.py +++ b/video/livevideo_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -70,9 +71,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/livevideo_submit.py b/video/livevideo_submit.py index ec69368..6ea94b1 100644 --- a/video/livevideo_submit.py +++ b/video/livevideo_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/livewall_callback.py b/video/livewall_callback.py index 8ac0434..963a0b3 100644 --- a/video/livewall_callback.py +++ b/video/livewall_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -68,10 +69,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/livewall_querymonitor.py b/video/livewall_querymonitor.py index a08a15f..1ca3c30 100644 --- a/video/livewall_querymonitor.py +++ b/video/livewall_querymonitor.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/livewall_submit.py b/video/livewall_submit.py index f87ac42..4cc4936 100644 --- a/video/livewall_submit.py +++ b/video/livewall_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/video_callback.py b/video/video_callback.py index 2dcd739..5650003 100644 --- a/video/video_callback.py +++ b/video/video_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,9 +70,15 @@ def check(self): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/video_query.py b/video/video_query.py index d63677e..c002dfa 100644 --- a/video/video_query.py +++ b/video/video_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -70,9 +71,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/video_submit.py b/video/video_submit.py index 46ce9f6..b6e479c 100644 --- a/video/video_submit.py +++ b/video/video_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -69,10 +70,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/video/videoimage_query.py b/video/videoimage_query.py index aaada63..7cf8935 100644 --- a/video/videoimage_query.py +++ b/video/videoimage_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -37,6 +37,7 @@ def __init__(self, secret_id, secret_key, business_id): self.secret_id = secret_id self.secret_key = secret_key self.business_id = business_id + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -70,9 +71,15 @@ def query(self,params): params["signature"] = self.gen_signature(params) try: - params = urlparse.urlencode(params).encode() - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/videosolution/videosolution_callback.py b/videosolution/videosolution_callback.py index efa20c5..82255f6 100644 --- a/videosolution/videosolution_callback.py +++ b/videosolution/videosolution_callback.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -65,10 +66,16 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/videosolution/videosolution_query.py b/videosolution/videosolution_query.py index 7d04031..2d9816f 100644 --- a/videosolution/videosolution_query.py +++ b/videosolution/videosolution_query.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -64,10 +65,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=10).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=10, read=10) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) diff --git a/videosolution/videosolution_submit.py b/videosolution/videosolution_submit.py index 6c9feb3..8960eb3 100644 --- a/videosolution/videosolution_submit.py +++ b/videosolution/videosolution_submit.py @@ -15,8 +15,8 @@ import hashlib import time import random -import urllib.request as urlrequest -import urllib.parse as urlparse +import urllib3 +from urllib.parse import urlencode import json from gmssl import sm3, func @@ -35,6 +35,7 @@ def __init__(self, secret_id, secret_key): """ self.secret_id = secret_id self.secret_key = secret_key + self.http = urllib3.PoolManager() # 初始化连接池 def gen_signature(self, params=None): """生成签名信息 @@ -66,10 +67,16 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: - params = urlparse.urlencode(params).encode("utf8") - request = urlrequest.Request(self.API_URL, params) - content = urlrequest.urlopen(request, timeout=1).read() + try: + encoded_params = urlencode(params).encode("utf8") + response = self.http.request( + 'POST', + self.API_URL, + body=encoded_params, + headers={'Content-Type': 'application/x-www-form-urlencoded'}, + timeout=urllib3.Timeout(connect=1.0, read=1.0) + ) + content = response.data return json.loads(content) except Exception as ex: print("调用API接口失败:", str(ex)) From e6eec0aca16c728aa4382aa8b6d7b55c33b4699b Mon Sep 17 00:00:00 2001 From: yeqiang02 Date: Tue, 16 Jul 2024 19:50:57 +0800 Subject: [PATCH 2/2] =?UTF-8?q?OMSEC-112581=20=E3=80=90=E5=90=8E=E7=AB=AF?= =?UTF-8?q?=E3=80=91=E3=80=90=E5=AE=98=E7=BD=91demo=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E3=80=91=E6=89=80=E6=9C=89=E8=AF=AD=E8=A8=80=E7=9A=84=E7=A4=BA?= =?UTF-8?q?=E4=BE=8B=E4=BB=A3=E7=A0=81=E5=A2=9E=E5=8A=A0=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E6=B1=A0=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 【后端】【官网demo优化】所有语言的示例代码增加连接池配置 --- aigc/aigc_stream_callback.py | 2 +- aigc/aigc_stream_push.py | 2 +- audio/audio_callback.py | 2 +- audio/audio_check.py | 2 +- audio/audio_query.py | 2 +- audio/audio_submit.py | 2 +- audio/liveaudio_callback.py | 2 +- audio/liveaudio_check.py | 2 +- audio/liveaudio_feedback.py | 2 +- audio/liveaudio_queryextra.py | 2 +- audio/liveaudio_querymonitor.py | 2 +- audio/liveaudio_querytask.py | 2 +- crawler/crawler_callback.py | 2 +- crawler/crawler_job_submit.py | 2 +- crawler/crawler_submit.py | 2 +- digital/digital_callback.py | 2 +- digital/digital_submit.py | 2 +- filesolution/filesolution_callback.py | 2 +- filesolution/filesolution_query.py | 2 +- filesolution/filesolution_submit.py | 2 +- image/image_asynccheck.py | 2 +- image/image_callback.py | 2 +- image/image_check.py | 2 +- image/image_query.py | 2 +- image/image_submit.py | 2 +- image/imagelist_delete.py | 2 +- image/imagelist_query.py | 2 +- image/imagelist_submit.py | 2 +- image/imagelist_update.py | 2 +- keyword/keyword_delete.py | 2 +- keyword/keyword_query.py | 2 +- keyword/keyword_submit.py | 2 +- list/list_delete.py | 2 +- list/list_query.py | 2 +- list/list_submit.py | 2 +- list/list_update.py | 2 +- livevideosolution/livevideosolution_callback.py | 2 +- livevideosolution/livevideosolution_feedback.py | 2 +- livevideosolution/livevideosolution_queryaudio.py | 2 +- livevideosolution/livevideosolution_queryimage.py | 2 +- livevideosolution/livevideosolution_querymonitor.py | 2 +- livevideosolution/livevideosolution_submit.py | 2 +- mediasolution/mediasolution_callback.py | 2 +- mediasolution/mediasolution_submit.py | 2 +- report/report_callback.py | 2 +- report/report_submit.py | 2 +- text/text_batch_check.py | 2 +- text/text_check.py | 2 +- text/text_submit.py | 2 +- video/livevideo_callback.py | 2 +- video/livevideo_feedback.py | 2 +- video/livevideo_submit.py | 2 +- video/livewall_callback.py | 2 +- video/livewall_querymonitor.py | 2 +- video/livewall_submit.py | 2 +- video/video_submit.py | 2 +- videosolution/videosolution_callback.py | 2 +- videosolution/videosolution_query.py | 2 +- videosolution/videosolution_submit.py | 2 +- 59 files changed, 59 insertions(+), 59 deletions(-) diff --git a/aigc/aigc_stream_callback.py b/aigc/aigc_stream_callback.py index b2ffde1..62c5ff8 100644 --- a/aigc/aigc_stream_callback.py +++ b/aigc/aigc_stream_callback.py @@ -65,7 +65,7 @@ def check(self): params["signatureMethod"] = "MD5" params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/aigc/aigc_stream_push.py b/aigc/aigc_stream_push.py index 2c84932..3f0f93c 100644 --- a/aigc/aigc_stream_push.py +++ b/aigc/aigc_stream_push.py @@ -66,7 +66,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/audio_callback.py b/audio/audio_callback.py index f2026fe..5a0e0a4 100644 --- a/audio/audio_callback.py +++ b/audio/audio_callback.py @@ -69,7 +69,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/audio_check.py b/audio/audio_check.py index 852be41..fb76163 100644 --- a/audio/audio_check.py +++ b/audio/audio_check.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/audio_query.py b/audio/audio_query.py index a93bad7..07ca0d9 100644 --- a/audio/audio_query.py +++ b/audio/audio_query.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/audio_submit.py b/audio/audio_submit.py index 65f4b1d..6d2398d 100644 --- a/audio/audio_submit.py +++ b/audio/audio_submit.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/liveaudio_callback.py b/audio/liveaudio_callback.py index cf12cc9..f9087dc 100644 --- a/audio/liveaudio_callback.py +++ b/audio/liveaudio_callback.py @@ -69,7 +69,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/liveaudio_check.py b/audio/liveaudio_check.py index 6d8a833..2523590 100644 --- a/audio/liveaudio_check.py +++ b/audio/liveaudio_check.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/liveaudio_feedback.py b/audio/liveaudio_feedback.py index 8e4db10..43e5a6a 100644 --- a/audio/liveaudio_feedback.py +++ b/audio/liveaudio_feedback.py @@ -68,7 +68,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/liveaudio_queryextra.py b/audio/liveaudio_queryextra.py index ad8e6d5..a79a6c9 100644 --- a/audio/liveaudio_queryextra.py +++ b/audio/liveaudio_queryextra.py @@ -68,7 +68,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/liveaudio_querymonitor.py b/audio/liveaudio_querymonitor.py index 398b1b5..ae17704 100644 --- a/audio/liveaudio_querymonitor.py +++ b/audio/liveaudio_querymonitor.py @@ -68,7 +68,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/audio/liveaudio_querytask.py b/audio/liveaudio_querytask.py index 4f5f4f3..d881d00 100644 --- a/audio/liveaudio_querytask.py +++ b/audio/liveaudio_querytask.py @@ -68,7 +68,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/crawler/crawler_callback.py b/crawler/crawler_callback.py index 53baac6..c0358d7 100644 --- a/crawler/crawler_callback.py +++ b/crawler/crawler_callback.py @@ -66,7 +66,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/crawler/crawler_job_submit.py b/crawler/crawler_job_submit.py index a028470..dbab2d8 100644 --- a/crawler/crawler_job_submit.py +++ b/crawler/crawler_job_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/crawler/crawler_submit.py b/crawler/crawler_submit.py index 13a5765..6f733cf 100644 --- a/crawler/crawler_submit.py +++ b/crawler/crawler_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/digital/digital_callback.py b/digital/digital_callback.py index 2ec650c..485f1a3 100644 --- a/digital/digital_callback.py +++ b/digital/digital_callback.py @@ -66,7 +66,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/digital/digital_submit.py b/digital/digital_submit.py index b951e81..37b05b7 100644 --- a/digital/digital_submit.py +++ b/digital/digital_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/filesolution/filesolution_callback.py b/filesolution/filesolution_callback.py index 92c1d84..4dd6d6b 100644 --- a/filesolution/filesolution_callback.py +++ b/filesolution/filesolution_callback.py @@ -66,7 +66,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/filesolution/filesolution_query.py b/filesolution/filesolution_query.py index 1237de5..42da238 100644 --- a/filesolution/filesolution_query.py +++ b/filesolution/filesolution_query.py @@ -65,7 +65,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/filesolution/filesolution_submit.py b/filesolution/filesolution_submit.py index d9db066..50c1ced 100644 --- a/filesolution/filesolution_submit.py +++ b/filesolution/filesolution_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/image_asynccheck.py b/image/image_asynccheck.py index c6226f3..76f78ec 100644 --- a/image/image_asynccheck.py +++ b/image/image_asynccheck.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/image_callback.py b/image/image_callback.py index 58d0f04..66bd559 100644 --- a/image/image_callback.py +++ b/image/image_callback.py @@ -69,7 +69,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/image_check.py b/image/image_check.py index 120cf74..699cdde 100644 --- a/image/image_check.py +++ b/image/image_check.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/image_query.py b/image/image_query.py index 35feb87..db47ec4 100644 --- a/image/image_query.py +++ b/image/image_query.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/image_submit.py b/image/image_submit.py index bd09305..bb51bc4 100644 --- a/image/image_submit.py +++ b/image/image_submit.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/imagelist_delete.py b/image/imagelist_delete.py index 5b5dbc5..5195133 100644 --- a/image/imagelist_delete.py +++ b/image/imagelist_delete.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/imagelist_query.py b/image/imagelist_query.py index 53c124a..39caf07 100644 --- a/image/imagelist_query.py +++ b/image/imagelist_query.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/imagelist_submit.py b/image/imagelist_submit.py index a26cea5..b29317a 100644 --- a/image/imagelist_submit.py +++ b/image/imagelist_submit.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/image/imagelist_update.py b/image/imagelist_update.py index 383943a..a851090 100644 --- a/image/imagelist_update.py +++ b/image/imagelist_update.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/keyword/keyword_delete.py b/keyword/keyword_delete.py index 9c5d8a1..d486e81 100644 --- a/keyword/keyword_delete.py +++ b/keyword/keyword_delete.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/keyword/keyword_query.py b/keyword/keyword_query.py index a1c0f42..d703e79 100644 --- a/keyword/keyword_query.py +++ b/keyword/keyword_query.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/keyword/keyword_submit.py b/keyword/keyword_submit.py index cc5eac9..cc1de0a 100644 --- a/keyword/keyword_submit.py +++ b/keyword/keyword_submit.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/list/list_delete.py b/list/list_delete.py index f05dbe9..71a5c44 100644 --- a/list/list_delete.py +++ b/list/list_delete.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/list/list_query.py b/list/list_query.py index d258e22..096deee 100644 --- a/list/list_query.py +++ b/list/list_query.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/list/list_submit.py b/list/list_submit.py index 405994d..b47ea36 100644 --- a/list/list_submit.py +++ b/list/list_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/list/list_update.py b/list/list_update.py index 86431f2..40e7765 100644 --- a/list/list_update.py +++ b/list/list_update.py @@ -70,7 +70,7 @@ def query(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/livevideosolution/livevideosolution_callback.py b/livevideosolution/livevideosolution_callback.py index 7859008..aaff584 100644 --- a/livevideosolution/livevideosolution_callback.py +++ b/livevideosolution/livevideosolution_callback.py @@ -66,7 +66,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/livevideosolution/livevideosolution_feedback.py b/livevideosolution/livevideosolution_feedback.py index fd0ee72..1aa2921 100644 --- a/livevideosolution/livevideosolution_feedback.py +++ b/livevideosolution/livevideosolution_feedback.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/livevideosolution/livevideosolution_queryaudio.py b/livevideosolution/livevideosolution_queryaudio.py index baf6411..2843cc4 100644 --- a/livevideosolution/livevideosolution_queryaudio.py +++ b/livevideosolution/livevideosolution_queryaudio.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/livevideosolution/livevideosolution_queryimage.py b/livevideosolution/livevideosolution_queryimage.py index e3fac23..8a1eca5 100644 --- a/livevideosolution/livevideosolution_queryimage.py +++ b/livevideosolution/livevideosolution_queryimage.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/livevideosolution/livevideosolution_querymonitor.py b/livevideosolution/livevideosolution_querymonitor.py index 21ce3ce..654f567 100644 --- a/livevideosolution/livevideosolution_querymonitor.py +++ b/livevideosolution/livevideosolution_querymonitor.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/livevideosolution/livevideosolution_submit.py b/livevideosolution/livevideosolution_submit.py index 8ed3a15..b139660 100644 --- a/livevideosolution/livevideosolution_submit.py +++ b/livevideosolution/livevideosolution_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/mediasolution/mediasolution_callback.py b/mediasolution/mediasolution_callback.py index 6672995..c6c9fe2 100644 --- a/mediasolution/mediasolution_callback.py +++ b/mediasolution/mediasolution_callback.py @@ -66,7 +66,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/mediasolution/mediasolution_submit.py b/mediasolution/mediasolution_submit.py index 2a7376a..52a0a0a 100644 --- a/mediasolution/mediasolution_submit.py +++ b/mediasolution/mediasolution_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/report/report_callback.py b/report/report_callback.py index 7daf457..8dd6838 100644 --- a/report/report_callback.py +++ b/report/report_callback.py @@ -66,7 +66,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/report/report_submit.py b/report/report_submit.py index 80bd6d7..a8c45a0 100644 --- a/report/report_submit.py +++ b/report/report_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/text/text_batch_check.py b/text/text_batch_check.py index 8a6890d..9ee18e9 100644 --- a/text/text_batch_check.py +++ b/text/text_batch_check.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/text/text_check.py b/text/text_check.py index 3fe6722..b97115d 100644 --- a/text/text_check.py +++ b/text/text_check.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/text/text_submit.py b/text/text_submit.py index 9040d04..9529eda 100644 --- a/text/text_submit.py +++ b/text/text_submit.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/video/livevideo_callback.py b/video/livevideo_callback.py index 46e7a60..ce753f5 100644 --- a/video/livevideo_callback.py +++ b/video/livevideo_callback.py @@ -69,7 +69,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/video/livevideo_feedback.py b/video/livevideo_feedback.py index 0a95269..07de561 100644 --- a/video/livevideo_feedback.py +++ b/video/livevideo_feedback.py @@ -69,7 +69,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/video/livevideo_submit.py b/video/livevideo_submit.py index 6ea94b1..f0992f4 100644 --- a/video/livevideo_submit.py +++ b/video/livevideo_submit.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/video/livewall_callback.py b/video/livewall_callback.py index 963a0b3..9bab118 100644 --- a/video/livewall_callback.py +++ b/video/livewall_callback.py @@ -69,7 +69,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/video/livewall_querymonitor.py b/video/livewall_querymonitor.py index 1ca3c30..85d3b9b 100644 --- a/video/livewall_querymonitor.py +++ b/video/livewall_querymonitor.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/video/livewall_submit.py b/video/livewall_submit.py index 4cc4936..659765a 100644 --- a/video/livewall_submit.py +++ b/video/livewall_submit.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/video/video_submit.py b/video/video_submit.py index b6e479c..642c8f0 100644 --- a/video/video_submit.py +++ b/video/video_submit.py @@ -70,7 +70,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/videosolution/videosolution_callback.py b/videosolution/videosolution_callback.py index 82255f6..7499527 100644 --- a/videosolution/videosolution_callback.py +++ b/videosolution/videosolution_callback.py @@ -66,7 +66,7 @@ def check(self): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/videosolution/videosolution_query.py b/videosolution/videosolution_query.py index 2d9816f..b991f24 100644 --- a/videosolution/videosolution_query.py +++ b/videosolution/videosolution_query.py @@ -65,7 +65,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST', diff --git a/videosolution/videosolution_submit.py b/videosolution/videosolution_submit.py index 8960eb3..9d4d675 100644 --- a/videosolution/videosolution_submit.py +++ b/videosolution/videosolution_submit.py @@ -67,7 +67,7 @@ def check(self, params): # params["signatureMethod"] = "SM3" # 签名方法，默认MD5，支持SM3 params["signature"] = self.gen_signature(params) - try: + try: encoded_params = urlencode(params).encode("utf8") response = self.http.request( 'POST',