python_setup/webapi.py at master · wblong/python_setup · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
#!/usr/bin/env python
#coding: utf-8

import os, math, sys, time
import codecs, socket,urllib,urllib2,urlparse, json, hashlib, random, traceback, platform
import logging
import logging.config
import util

from optparse import OptionParser
from datetime import datetime

class WebApi:
    def __init__(self,logger):
        self.logger = logger
    def http_get(self,url=None,debug=False):
        if url is None:
            self.logger.debug("url is None")
            return False,None
        content=None
        result=True
        connect=None
        try:
            if debug == True:
                self.logger.debug("request: {}".format(url))
            connect = urllib2.urlopen(url, timeout=3)
            content = connect.read()
            if debug == True:
                self.logger.debug("response: '{}'".format(content))
            result = True
        except urllib2.HTTPError as err:
            self.logger.error("error: '{}, url:{}".format(err, url))
            result = False
        except urllib2.URLError as err:
            self.logger.error("error: '{}', url:{}".format(err, url))
            if hasattr(err, 'code'):
                content = err.read()
                self.logger.debug(content)
            elif hasattr(err, 'reason'):
                pass
            result = False
        except socket.timeout as err:
            self.logger.error(" error: '{}', url:{}".format(err, url))
            result = False
        finally:
            if connect:
                connect.close()
                del connect
            return result, content

    def http_post(self,url=None,data=None,debug=False):
        if url is None:
            self.logger.debug("url is None")
            return False,None
        content=None
        result=True
        connect=None
        req_data=None
        headerdata = {"Content-type": "application/json"}
        if data is not None:
            req_data=json.dumps(data)
            self.logger.debug("request data:{}".format(req_data))
        try:
            if debug == True:
                self.logger.debug("request: {}".format(url))
            req=urllib2.Request(url,req_data,headerdata)
            if debug == True:
                self.logger.debug("request full url:{};data:{}".format(req.get_full_url(),req.get_data()))
            connect = urllib2.urlopen(req, timeout=3)
            content = connect.read()
            if debug == True:
                self.logger.debug("response: '{}'".format(content))
            result = True
        except urllib2.HTTPError as err:
            self.logger.error("error: '{}, url:{}".format(err, url))
            result = False
        except urllib2.URLError as err:
            self.logger.error("error: '{}', url:{}".format(err, url))
            if hasattr(err, 'code'):
                content = err.read()
                self.logger.debug(content)
            elif hasattr(err, 'reason'):
                pass
            result = False
        except socket.timeout as err:
            self.logger.error(" error: '{}', url:{}".format(err, url))
            result = False
        finally:
            if connect:
                connect.close()
                del connect
            return result, content