sinaweibopy3第三方模块包，调用微博API接口

sinaweibopy3模块调用微博接口

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


import urllib.request
import urllib.parse
import json
import logging
import time


# general json object that can bind any fields but also act as a dict.
# a json class inhert dict class which can use d['key'] or d.key to get
class JsonDict(dict):
    def __getattr__(self, attr):
        return self[attr]

    def __setattr__(self, attr, value):
        self[attr] = value

# convert json object to python object.
def _obj_hook(paris):
    odict = JsonDict()
    for key, value in paris.items():
        odict[str(key)] = value
    return odict




# Encode parameters
def _encode_params(**kw):
    args = []
    for key, value in kw.items():
        para = value.encode('utf-8') if isinstance(value, str) else str(value)
        args.append('%s=%s' % (key, urllib.parse.quote(para)))
    return '&'.join(args)




# Build a multipart/form-data body with generated random boundary.
def _encode_multipart(**kw):
    # 'encode mulyipart data'
    boundary = '----------%s' % hex(int(time.time() * 1000))
    data = []
    for key, value in kw.items():
        data.append('--%s' % boundary)
        if hasattr(value, 'read'):
            filename = getattr(value, 'name', '')
            name = filename.rfind('.')
            ext = filename[name:].lower() if name != (-1) else ""
            content = value.read()
            content = content.decode('ISO-8859-1')
            data.append('Content-Disposition: form-data; name="%s"; filename="hidden"' % key)
            data.append('Content-Length: %d' % len(content))
            data.append('Content-Type: %s\r\n' % _guess_content_type(ext))
            data.append(content)
        else:
            data.append('Content-Disposition: form-data; name="%s"\r\n' % key)
            data.append(value if isinstance(value, str) else value.decode('utf-8'))
    data.append('--%s--\r\n' % boundary)
    return '\r\n'.join(data), boundary




_CONTENT_TYPES = {'.png': 'image/png', '.gif': 'image/gif', '.jpg': 'image/jpeg',
                  '.jpeg': 'image/jpeg', '.jpe': 'image/jpeg'}




def _guess_content_type(ext):
    return _CONTENT_TYPES.get(ext, 'application/octet-stream')




_HTTP_GET = 0
_HTTP_POST = 1
_HTTP_UPLOAD = 2




def _http_get(url, authorization=None, **kw):
    logging.info('GET %s' % url)
    return _http_request(url, _HTTP_GET, authorization, **kw)




def _http_post(url, authorization=None, **kw):
    logging.info('POST %s' % url)
    return _http_request(url, _HTTP_POST, authorization, **kw)




def _http_upload(url, authorization=None, **kw):
    logging.info('UPLOAD %s' % url)
    return _http_request(url, _HTTP_UPLOAD, authorization, **kw)




# send an http request and expect to return a json object if no error.
def _http_request(url, method, authorization, **kw):
    params = None
    boundary = None
    if method == _HTTP_UPLOAD:
        params, boundary = _encode_multipart(**kw)
    else:
        params = _encode_params(**kw)
    http_url = '%s?%s' % (url, params) if method == _HTTP_GET else url
    http_para = None if method == _HTTP_GET else params.encode(encoding='utf-8')
    # print(http_para)
    req = urllib.request.Request(http_url, data=http_para)
    if authorization:
        req.add_header('Authorization', 'OAuth2 %s' % authorization)
    if boundary:
        req.add_header('Content-Type', 'multipart/form-data; boundary=%s' % boundary)
    resq = urllib.request.urlopen(req)
    body = resq.read().decode("utf-8")
    result = json.loads(body, object_hook=_obj_hook)
    if 'error_code' in result:
        print('error')
    return result




class HttpObject(object):
    'post get or updload object'


    def __init__(self, client, method):
        self.client = client
        self.method = method


    def __getattr__(self, attr):
        def wrap(**kw):
            'request param'
            if self.client.is_expires():
                raise AttributeError
            return _http_request('%s%s.json' % (self.client.api_url, attr.replace('__', '/')), self.method,
                                 self.client.access_token, **kw)


        return wrap




# APIClient class
class APIClient(object):
    def __init__(self, app_key, app_secret, redirect_uri=None, response_type='code', domain='api.weibo.com',
                 version='2'):
        self.client_id = app_key
        self.client_secret = app_secret
        self.redirect_uri = redirect_uri
        self.response_type = response_type
        self.auth_url = 'https://%s/oauth2/' % domain
        self.api_url = 'https://%s/%s/' % (domain, version)
        self.access_token = None
        self.expires = 0.0  # 到期
        self.get = HttpObject(self, _HTTP_GET)
        self.post = HttpObject(self, _HTTP_POST)
        self.upload = HttpObject(self, _HTTP_UPLOAD)


    # get authorize url得到授权url
    def get_authorize_url(self):
        return "https://api.weibo.com/oauth2/authorize?response_type=code&client_id=%s&redirect_uri=%s" % (
        self.client_id, self.redirect_uri)


    # post a request and then get a access_token
    def request_access_token(self, code):
        result = _http_post('%s%s' % (self.auth_url, 'access_token'),
                            client_id=self.client_id,
                            client_secret=self.client_secret,
                            redirect_uri=self.redirect_uri,
                            code=code, grant_type='authorization_code')
        result.expires_in += int(time.time())
        return result


    # set access_token and expires_in
    def set_access_token(self, access_token, expires_in):
        self.access_token = str(access_token)
        self.expires = float(expires_in)


    # Determine if the access token expires
    def is_expires(self):
        return not self.access_token or time.time() > self.expires


    # Custom function:Used to get the latest public Weibo
    def public_timeline(self):
        '''
        get new public weibo,the parameters followed can be used in _http_get in this method
        access_token : (string) the token you got after OAuth
        count : (int) the record items in one single page,default 50 items
        page : (int) the page number,default one page
        base_app : (int) whether get data in current app or not,0 is not(all data),1 is yes(current app),default 0
        '''
        result = _http_get('%s' % (self.api_url) + 'statuses/public_timeline.json',
                           access_token=self.access_token,
                           count=50,
                           page=1,
                           base_app=0,
                           )
        return result




# 微博开放平台的配置

app_key = ' '
app_secret = ' '
redirect_url = ' '
weiboApi = APIClient(app_key,app_secret,redirect_url)


if __name__ == '__main__':
    print(weiboApi.get_authorize_url)

’ 内容’ 在微博开放平台的位置 ：
【
app_key = 我的应用 -> 应用信息 -> 基本信息 -> app_key ：
app_secret = 同上 -> app_secret
redirect_url = 我的应用 -> 应用信息 -> 高级信息 -> OAuth2.0授权 -> 授权回调页 ：
】

• 编辑好信息后 在后台右键直接运行，会输出 print的数据 ：