Python http&ftp函数应用

爱被打了一巴掌 2023-02-26 15:25 3阅读 0赞

// ip_port: ip + ":" + str(port)
    def http302(ip_port, request_url):
        try:
            httpClient = httplib.HTTPConnection(ip_port, timeout=20)
            httpClient.request("GET", request_url)
            resp = httpClient.getresponse()
            status = resp.status
            count = 1
            while status == 302:
                if count > 3:
                    httpClient.close()
                    raise Exception("302 is greater than 3 times, request_url: " + request_url)
                url_302 = resp.msg.dict['location']
                ip_port_new, request_url_302 = get_request_url_302(ip_port, url_302)
                httpClient.close()
                if request_url_302 is None or len(request_url_302) == 0:
                    raise Exception("request_url_302 is abnormal, request_url: " + request_url)
                httpClient = httplib.HTTPConnection(ip_port_new, timeout=20)
                httpClient.request("GET", request_url_302)
                resp = httpClient.getresponse()
                status = resp.status
                count += 1
            read = resp.read()
            httpClient.close()
            return status, read
        except Exception, e:
            print e
            return 0, ""

def http_with_json(ip, port, request_uri,jsonStr):
        try:
            httpClient = httplib.HTTPConnection(ip + ":" + str(port))
            httpClient.request("POST", request_uri, jsonStr)
            resp = httpClient.getresponse()
            status = resp.status
            read = resp.read()
            httpClient.close()
            return status, read
        except Exception, e:
            print e

def http_with_Auth(ip, port, request_uri):
        try:
            tagStr = "zxcdn::ott4IAS!:" + request_uri
            url = "http://" + ip + ":" + str(port) + request_uri
            httpClient = httplib.HTTPConnection(ip + ":" + str(port))
            headers = {
                "X-Auth": get_md5(tagStr)
            }
            httpClient.request("POST", url, "", headers)
            resp = httpClient.getresponse()
            status = resp.status
            read = resp.read()
            httpClient.close()
            return status, read
        except Exception, e:
            print e

# 获取当前utc时间秒数
    currUtcTime = time.mktime(datetime.datetime.utcnow().timetuple())
    
    begintime = time.strftime("%Y%m%dT%H%M%S", time.localtime(currUtcTime - tvodTime + tvodTime / 4))

def ftp_use():
        try:
            client = paramiko.SSHClient()
            client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
            client.connect(str(ip), port=22, username="root", password="root", timeout=10)
    
            time1 = datetime.datetime.now().strftime("%Y%m%dT%H%M%SZ")
    
            timeList = []
    
            for timeStr in timeList:
                stdin, stdout, stderr = client.exec_command("touch -f /home/" + filename)
                error = stderr.readlines()
            return none
        except Exception, e:
            print e
        finally:
            // 注意关闭
            client.close()