|
@@ -277,6 +277,7 @@ class SPClient(BaseClient):
|
|
|
@param asins：如果recommendationType为KEYWORDS_FOR_ASINS时，为必填项
|
|
@param asins：如果recommendationType为KEYWORDS_FOR_ASINS时，为必填项
|
|
|
@param userSelectedKeyword：是否参考选择的keyword
|
|
@param userSelectedKeyword：是否参考选择的keyword
|
|
|
@param recommendationType：类型选择，必填
|
|
@param recommendationType：类型选择，必填
|
|
|
|
|
+ @param locale:pass
|
|
|
"""
|
|
"""
|
|
|
headers = {"Accept":"application/vnd.spkeywordsrecommendation.v3+json",
|
|
headers = {"Accept":"application/vnd.spkeywordsrecommendation.v3+json",
|
|
|
"Content-Type":"application/vnd.spkeywordsrecommendation.v3+json"}
|
|
"Content-Type":"application/vnd.spkeywordsrecommendation.v3+json"}
|
|
@@ -382,7 +383,7 @@ class SPClient(BaseClient):
|
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
|
de_file = json.load(data)
|
|
de_file = json.load(data)
|
|
|
- logger.info(f"解压完成：{de_file}")
|
|
|
|
|
|
|
+ # logger.info(f"解压完成：{de_file}")
|
|
|
# print(de_file)
|
|
# print(de_file)
|
|
|
return de_file
|
|
return de_file
|
|
|
else:
|
|
else:
|
|
@@ -586,7 +587,7 @@ class SBClient(BaseClient):
|
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
|
de_file = json.load(data)
|
|
de_file = json.load(data)
|
|
|
- logger.info(f"解压完成：{de_file}")
|
|
|
|
|
|
|
+ # logger.info(f"解压完成：{de_file}")
|
|
|
# print(de_file)
|
|
# print(de_file)
|
|
|
return de_file
|
|
return de_file
|
|
|
else:
|
|
else:
|
|
@@ -673,7 +674,7 @@ class SBClient(BaseClient):
|
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
|
de_file = json.load(data)
|
|
de_file = json.load(data)
|
|
|
- logger.info(f"解压完成：{de_file}")
|
|
|
|
|
|
|
+ # logger.info(f"解压完成：{de_file}")
|
|
|
# print(de_file)
|
|
# print(de_file)
|
|
|
return de_file
|
|
return de_file
|
|
|
else:
|
|
else:
|
|
@@ -848,7 +849,7 @@ class SDClient(BaseClient):
|
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
|
de_file = json.load(data)
|
|
de_file = json.load(data)
|
|
|
- logger.info(f"解压完成：{de_file}")
|
|
|
|
|
|
|
+ # logger.info(f"解压完成：{de_file}")
|
|
|
# print(de_file)
|
|
# print(de_file)
|
|
|
return de_file
|
|
return de_file
|
|
|
else:
|
|
else:
|
|
@@ -933,7 +934,7 @@ class SDClient(BaseClient):
|
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
with s3_.open(file_path, 'rb') as f: # 读取s3数据
|
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
data = gzip.GzipFile(fileobj=f, mode='rb')
|
|
|
de_file = json.load(data)
|
|
de_file = json.load(data)
|
|
|
- logger.info(f"解压完成：{de_file}")
|
|
|
|
|
|
|
+ # logger.info(f"解压完成：{de_file}")
|
|
|
# print(de_file)
|
|
# print(de_file)
|
|
|
return de_file
|
|
return de_file
|
|
|
else:
|
|
else:
|
huangyifan