Python采用并发查询mysql以及调用API灌数据 （四）- Python封装Http请求基本类方法

# coding:utf-8
import urllib2,json

class PostHelper(object): # 继承object类所有方法

    def post(self, url , headers , body):
        self.data = json.dumps(body)
        try:
            request = urllib2.Request(url, self.data, headers)  # urllib2用一个Request对象来映射你提出的HTTP请求
            print request
            response = urllib2.urlopen(request)  # 通过调用urlopen并传入Request对象，将返回一个相关请求response对象
            print response
            message = response.read()  # 这个应答对象如同一个文件对象，所以你可以在Response中调用.read()
            print "message=",message
            return self.check_ResuleCode(message)
        except Exception as e:
            print str(e)

    def check_ResuleCode(self,message):
        hjson = json.loads(message)
        # print hjson['resultCode']
        if hjson['resultCode'] == 0:
            # print "implements sucessful!"
            return True
        else:
            # print "implements fail!"
            return False

if __name__ == "__main__":

    # 定义请求参数
    url='你需要发送的API请求的url'
    body = {‘######注释请求体######’}
    headers={
        'Content-Type':'application/json',
        ....
        # 补充你所需的请求头信息
    }     #头部

    # 初始化请求类
    httpPost = PostHelper()

    # 执行post请求
    result = httpPost.post(url,headers,body)

    # 判断是否执行成功
    if result:
        print "insert sucessful"
    else:
        print "insert fail"

message= {"resultCode":0,"message":null,"data":{"id":"1067....,"accessory":null}
insert sucessful

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

from tools.PostTools import PostHelper

if __name__ == "__main__":

    # 定义请求参数
    url='服务API接口url地址'
    body = {‘######注释请求体######’}
    headers={
        'Content-Type':'application/json',
        ..... 头部参数
    }     #头部

    # 初始化请求类
    httpPost = PostHelper()

    # 执行post请求
    result = httpPost.post(url,headers,body)

    # 判断是否执行成功
    if result:
        print "insert sucessful"
    else:
        print "insert fail"