淘宝SDK – 自用的Python3版本 - WBB - 广州奔讯信息科技有限公司

Python的2和3问题很头疼

淘宝的sdk部分做了3的处理，部分又没做，主要体现在base.py

新手，之前彻底没找到linux下用2to3的方法，官方也不说可以 yum install python34-tools

所以自己手工修复了，问题全部出在base，代码有问题的话可能是wp转义了，下载：http://pan.baidu.com/s/1eR55Lz8

# -*- coding: utf-8 -*-
'''
Created on 2012-7-3

@author: lihao
'''

try: import httplib
except ImportError:
    import http.client as httplib
import urllib
import time
import hashlib
import json
import top
import itertools
import mimetypes

'''
定义一些系统变量
'''

SYSTEM_GENERATE_VERSION = "taobao-sdk-python-20161228"

P_APPKEY = "app_key"
P_API = "method"
P_SESSION = "session"
P_ACCESS_TOKEN = "access_token"
P_VERSION = "v"
P_FORMAT = "format"
P_TIMESTAMP = "timestamp"
P_SIGN = "sign"
P_SIGN_METHOD = "sign_method"
P_PARTNER_ID = "partner_id"

P_CODE = 'code'
P_SUB_CODE = 'sub_code'
P_MSG = 'msg'
P_SUB_MSG = 'sub_msg'


N_REST = '/router/rest'

def sign(secret, parameters):
    #===========================================================================
    # '''签名方法
    # @param secret: 签名需要的密钥
    # @param parameters: 支持字典和string两种
    # '''
    #===========================================================================
    # 如果parameters 是字典类的话
    if hasattr(parameters, "items"):
        #keys = parameters.keys()
        #keys.sort()
        keys = sorted(parameters)        

        parameters = "%s%s%s" % (secret,
            str().join('%s%s' % (key, parameters[key]) for key in keys),
            secret)
    sign = hashlib.md5(parameters.encode('utf-8')).hexdigest().upper()
    return sign

def mixStr(pstr):
    if(isinstance(pstr, str)):
        return pstr
    elif(isinstance(pstr, unicode)):
        return pstr.encode('utf-8')
    else:
        return str(pstr)
    
class FileItem(object):
    def __init__(self,filename=None,content=None):
        self.filename = filename
        self.content = content

class MultiPartForm(object):
    """Accumulate the data to be used when posting a form."""

    def __init__(self):
        self.form_fields = []
        self.files = []
        self.boundary = "PYTHON_SDK_BOUNDARY"
        return
    
    def get_content_type(self):
        return 'multipart/form-data; boundary=%s' % self.boundary

    def add_field(self, name, value):
        """Add a simple field to the form data."""
        self.form_fields.append((name, str(value)))
        return

    def add_file(self, fieldname, filename, fileHandle, mimetype=None):
        """Add a file to be uploaded."""
        body = fileHandle.read()
        if mimetype is None:
            mimetype = mimetypes.guess_type(filename)[0] or 'application/octet-stream'
        self.files.append((mixStr(fieldname), mixStr(filename), mixStr(mimetype), mixStr(body)))
        return
    
    def __str__(self):
        """Return a string representing the form data, including attached files."""
        # Build a list of lists, each containing "lines" of the
        # request.  Each part is separated by a boundary string.
        # Once the list is built, return a string where each
        # line is separated by '\r\n'.  
        parts = []
        part_boundary = '--' + self.boundary
        
        # Add the form fields
        parts.extend(
            [ part_boundary,
              'Content-Disposition: form-data; name="%s"' % name,
              'Content-Type: text/plain; charset=UTF-8',
              '',
              value,
            ]
            for name, value in self.form_fields
            )
        
        # Add the files to upload
        parts.extend(
            [ part_boundary,
              'Content-Disposition: file; name="%s"; filename="%s"' % \
                 (field_name, filename),
              'Content-Type: %s' % content_type,
              'Content-Transfer-Encoding: binary',
              '',
              body,
            ]
            for field_name, filename, content_type, body in self.files
            )
        
        # Flatten the list and add closing boundary marker,
        # then return CR+LF separated data
        flattened = list(itertools.chain(*parts))
        flattened.append('--' + self.boundary + '--')
        flattened.append('')
        return '\r\n'.join(flattened)

class TopException(Exception):
    #===========================================================================
    # 业务异常类
    #===========================================================================
    def __init__(self):
        self.errorcode = None
        self.message = None
        self.subcode = None
        self.submsg = None
        self.application_host = None
        self.service_host = None
    
    def __str__(self, *args, **kwargs):
        sb = "errorcode=" + mixStr(self.errorcode) +\
            " message=" + mixStr(self.message) +\
            " subcode=" + mixStr(self.subcode) +\
            " submsg=" + mixStr(self.submsg) +\
            " application_host=" + mixStr(self.application_host) +\
            " service_host=" + mixStr(self.service_host)
        return sb
       
class RequestException(Exception):
    #===========================================================================
    # 请求连接异常类
    #===========================================================================
    pass

class RestApi(object):
    #===========================================================================
    # Rest api的基类
    #===========================================================================
    
    def __init__(self, domain='gw.api.taobao.com', port = 80):
        #=======================================================================
        # 初始化基类
        # Args @param domain: 请求的域名或者ip
        #      @param port: 请求的端口
        #=======================================================================
        self.__domain = domain
        self.__port = port
        self.__httpmethod = "POST"
        if(top.getDefaultAppInfo()):
            self.__app_key = top.getDefaultAppInfo().appkey
            self.__secret = top.getDefaultAppInfo().secret
        
    def get_request_header(self):
        return {
                 'Content-type': 'application/x-www-form-urlencoded;charset=UTF-8',
                 "Cache-Control": "no-cache",
                 "Connection": "Keep-Alive",
        }
        
    def set_app_info(self, appinfo):
        #=======================================================================
        # 设置请求的app信息
        # @param appinfo: import top
        #                 appinfo top.appinfo(appkey,secret)
        #=======================================================================
        self.__app_key = appinfo.appkey
        self.__secret = appinfo.secret
        
    def getapiname(self):
        return ""
    
    def getMultipartParas(self):
        return [];

    def getTranslateParas(self):
        return {};
    
    def _check_requst(self):
        pass
    
    def getResponse(self, authrize=None, timeout=30):
        #=======================================================================
        # 获取response结果
        #=======================================================================
        connection = httplib.HTTPConnection(self.__domain, self.__port,  timeout)
        sys_parameters = {
            P_FORMAT: 'json',
            P_APPKEY: self.__app_key,
            P_SIGN_METHOD: "md5",
            P_VERSION: '2.0',
            P_TIMESTAMP: str(int(time.time() * 1000)),
            P_PARTNER_ID: SYSTEM_GENERATE_VERSION,
            P_API: self.getapiname(),
        }
        if authrize is not None:
            sys_parameters[P_SESSION] = authrize
        application_parameter = self.getApplicationParameters()
        sign_parameter = sys_parameters.copy()
        sign_parameter.update(application_parameter)
        sys_parameters[P_SIGN] = sign(self.__secret, sign_parameter)
        connection.connect()
        
        header = self.get_request_header();
        if(self.getMultipartParas()):
            form = MultiPartForm()
            for key, value in application_parameter.items():
                form.add_field(key, value)
            for key in self.getMultipartParas():
                fileitem = getattr(self,key)
                if(fileitem and isinstance(fileitem,FileItem)):
                    form.add_file(key,fileitem.filename,fileitem.content)
            body = str(form)
            header['Content-type'] = form.get_content_type()
        else:
            body = urllib.parse.urlencode(application_parameter)
            
        url = N_REST + "?" + urllib.parse.urlencode(sys_parameters)
        connection.request(self.__httpmethod, url, body=body, headers=header)
        response = connection.getresponse();
        if response.status is not 200:
            raise RequestException('invalid http status ' + str(response.status) + ',detail body:' + response.read())
        result = response.read()
        jsonobj = json.loads(result.decode('utf-8'))
        if "error_response" in jsonobj:
            error = TopException()
            if jsonobj["error_response"].has_key(P_CODE) :
                error.errorcode = jsonobj["error_response"][P_CODE]
            if jsonobj["error_response"].has_key(P_MSG) :
                error.message = jsonobj["error_response"][P_MSG]
            if jsonobj["error_response"].has_key(P_SUB_CODE) :
                error.subcode = jsonobj["error_response"][P_SUB_CODE]
            if jsonobj["error_response"].has_key(P_SUB_MSG) :
                error.submsg = jsonobj["error_response"][P_SUB_MSG]
            error.application_host = response.getheader("Application-Host", "")
            error.service_host = response.getheader("Location-Host", "")
            raise error
        return jsonobj
    
    
    def getApplicationParameters(self):
        application_parameter = {}
        for key, value in self.__dict__.items():
            if not key.startswith("__") and not key in self.getMultipartParas() and not key.startswith("_RestApi__") and value is not None :
                if(key.startswith("_")):
                    application_parameter[key[1:]] = value
                else:
                    application_parameter[key] = value
        #查询翻译字典来规避一些关键字属性
        translate_parameter = self.getTranslateParas()
        for key, value in application_parameter.items():
            if key in translate_parameter:
                application_parameter[translate_parameter[key]] = application_parameter[key]
                del application_parameter[key]
        return application_parameter

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

# -*- coding: utf-8 -*-

'''

Created on 2012-7-3

@author: lihao

'''

try: import httplib

except ImportError:

import http.client as httplib

import urllib

import time

import hashlib

import json

import top

import itertools

import mimetypes

'''

定义一些系统变量

'''

SYSTEM_GENERATE_VERSION = "taobao-sdk-python-20161228"

P_APPKEY = "app_key"

P_API = "method"

P_SESSION = "session"

P_ACCESS_TOKEN = "access_token"

P_VERSION = "v"

P_FORMAT = "format"

P_TIMESTAMP = "timestamp"

P_SIGN = "sign"

P_SIGN_METHOD = "sign_method"

P_PARTNER_ID = "partner_id"

P_CODE = 'code'

P_SUB_CODE = 'sub_code'

P_MSG = 'msg'

P_SUB_MSG = 'sub_msg'

N_REST = '/router/rest'

def sign(secret, parameters):

#===========================================================================

# '''签名方法

# @param secret: 签名需要的密钥

# @param parameters: 支持字典和string两种

# '''

#===========================================================================

# 如果parameters 是字典类的话

if hasattr(parameters, "items"):

#keys = parameters.keys()

#keys.sort()

keys = sorted(parameters)

parameters = "%s%s%s" % (secret,

str().join('%s%s' % (key, parameters[key]) for key in keys),

secret)

sign = hashlib.md5(parameters.encode('utf-8')).hexdigest().upper()

return sign

def mixStr(pstr):

if(isinstance(pstr, str)):

return pstr

elif(isinstance(pstr, unicode)):

return pstr.encode('utf-8')

else:

return str(pstr)

class FileItem(object):

def __init__(self,filename=None,content=None):

self.filename = filename

self.content = content

class MultiPartForm(object):

"""Accumulate the data to be used when posting a form."""

def __init__(self):

self.form_fields = []

self.files = []

self.boundary = "PYTHON_SDK_BOUNDARY"

return

def get_content_type(self):

return 'multipart/form-data; boundary=%s' % self.boundary

def add_field(self, name, value):

"""Add a simple field to the form data."""

self.form_fields.append((name, str(value)))

return

def add_file(self, fieldname, filename, fileHandle, mimetype=None):

"""Add a file to be uploaded."""

body = fileHandle.read()

if mimetype is None:

mimetype = mimetypes.guess_type(filename)[0] or 'application/octet-stream'

self.files.append((mixStr(fieldname), mixStr(filename), mixStr(mimetype), mixStr(body)))

return

def __str__(self):

"""Return a string representing the form data, including attached files."""

# Build a list of lists, each containing "lines" of the

# request. Each part is separated by a boundary string.

# Once the list is built, return a string where each

# line is separated by '\r\n'.

parts = []

part_boundary = '--' + self.boundary

# Add the form fields

parts.extend(

[ part_boundary,

'Content-Disposition: form-data; name="%s"' % name,

'Content-Type: text/plain; charset=UTF-8',

'',

value,

]

for name, value in self.form_fields

)

# Add the files to upload

parts.extend(

[ part_boundary,

'Content-Disposition: file; name="%s"; filename="%s"' % \

(field_name, filename),

'Content-Type: %s' % content_type,

'Content-Transfer-Encoding: binary',

'',

body,

]

for field_name, filename, content_type, body in self.files

)

# Flatten the list and add closing boundary marker,

# then return CR+LF separated data

flattened = list(itertools.chain(*parts))

flattened.append('--' + self.boundary + '--')

flattened.append('')

return '\r\n'.join(flattened)

class TopException(Exception):

#===========================================================================

# 业务异常类

#===========================================================================

def __init__(self):

self.errorcode = None

self.message = None

self.subcode = None

self.submsg = None

self.application_host = None

self.service_host = None

def __str__(self, *args, **kwargs):

sb = "errorcode=" + mixStr(self.errorcode) +\

" message=" + mixStr(self.message) +\

" subcode=" + mixStr(self.subcode) +\

" submsg=" + mixStr(self.submsg) +\

" application_host=" + mixStr(self.application_host) +\

" service_host=" + mixStr(self.service_host)

return sb

class RequestException(Exception):

#===========================================================================

# 请求连接异常类

#===========================================================================

pass

class RestApi(object):

#===========================================================================

# Rest api的基类

#===========================================================================

def __init__(self, domain='gw.api.taobao.com', port = 80):

#=======================================================================

# 初始化基类

# Args @param domain: 请求的域名或者ip

# @param port: 请求的端口

#=======================================================================

self.__domain = domain

self.__port = port

self.__httpmethod = "POST"

if(top.getDefaultAppInfo()):

self.__app_key = top.getDefaultAppInfo().appkey

self.__secret = top.getDefaultAppInfo().secret

def get_request_header(self):

return {

'Content-type': 'application/x-www-form-urlencoded;charset=UTF-8',

"Cache-Control": "no-cache",

"Connection": "Keep-Alive",

}

def set_app_info(self, appinfo):

#=======================================================================

# 设置请求的app信息

# @param appinfo: import top

# appinfo top.appinfo(appkey,secret)

#=======================================================================

self.__app_key = appinfo.appkey

self.__secret = appinfo.secret

def getapiname(self):

return ""

def getMultipartParas(self):

return [];

def getTranslateParas(self):

return {};

def _check_requst(self):

pass

def getResponse(self, authrize=None, timeout=30):

#=======================================================================

# 获取response结果

#=======================================================================

connection = httplib.HTTPConnection(self.__domain, self.__port, timeout)

sys_parameters = {

P_FORMAT: 'json',

P_APPKEY: self.__app_key,

P_SIGN_METHOD: "md5",

P_VERSION: '2.0',

P_TIMESTAMP: str(int(time.time() * 1000)),

P_PARTNER_ID: SYSTEM_GENERATE_VERSION,

P_API: self.getapiname(),

}

if authrize is not None:

sys_parameters[P_SESSION] = authrize

application_parameter = self.getApplicationParameters()

sign_parameter = sys_parameters.copy()

sign_parameter.update(application_parameter)

sys_parameters[P_SIGN] = sign(self.__secret, sign_parameter)

connection.connect()

header = self.get_request_header();

if(self.getMultipartParas()):

form = MultiPartForm()

for key, value in application_parameter.items():

form.add_field(key, value)

for key in self.getMultipartParas():

fileitem = getattr(self,key)

if(fileitem and isinstance(fileitem,FileItem)):

form.add_file(key,fileitem.filename,fileitem.content)

body = str(form)

header['Content-type'] = form.get_content_type()

else:

body = urllib.parse.urlencode(application_parameter)

url = N_REST + "?" + urllib.parse.urlencode(sys_parameters)

connection.request(self.__httpmethod, url, body=body, headers=header)

response = connection.getresponse();

if response.status is not 200:

raise RequestException('invalid http status ' + str(response.status) + ',detail body:' + response.read())

result = response.read()

jsonobj = json.loads(result.decode('utf-8'))

if "error_response" in jsonobj:

error = TopException()

if jsonobj["error_response"].has_key(P_CODE) :

error.errorcode = jsonobj["error_response"][P_CODE]

if jsonobj["error_response"].has_key(P_MSG) :

error.message = jsonobj["error_response"][P_MSG]

if jsonobj["error_response"].has_key(P_SUB_CODE) :

error.subcode = jsonobj["error_response"][P_SUB_CODE]

if jsonobj["error_response"].has_key(P_SUB_MSG) :

error.submsg = jsonobj["error_response"][P_SUB_MSG]

error.application_host = response.getheader("Application-Host", "")

error.service_host = response.getheader("Location-Host", "")

raise error

return jsonobj

def getApplicationParameters(self):

application_parameter = {}

for key, value in self.__dict__.items():

if not key.startswith("__") and not key in self.getMultipartParas() and not key.startswith("_RestApi__") and value is not None :

if(key.startswith("_")):

application_parameter[key[1:]] = value

else:

application_parameter[key] = value

#查询翻译字典来规避一些关键字属性

translate_parameter = self.getTranslateParas()

for key, value in application_parameter.items():

if key in translate_parameter:

application_parameter[translate_parameter[key]] = application_parameter[key]

del application_parameter[key]

return application_parameter

转载请注明来源：WBB » 淘宝SDK – 自用的Python3版本

Hiwbb.com

淘宝SDK – 自用的Python3版本

Hi，您需要填写昵称和邮箱！