Python3發送多線程請求

import requests

import json

import threading

import time

import uuid

import random

import datetime

import redis

import logging

import numpy as np

import math

pool = redis.ConnectionPool(host='localhost', port=6379)

logger = logging.getLogger('requset_log')

logger.setLevel(logging.DEBUG)

log_file = logging.FileHandler('test.log', encoding='utf-8')

log_file.setLevel(logging.DEBUG)

formatter = logging.Formatter(

    '%(asctime)s - %(name)s - %(levelname)s - %(message)s')

log_file.setFormatter(formatter)

logger.addHandler(log_file)

url = 'http://ip:port/ctrl/api/get?app_id=8d25bb3617814922&server_name=Utilities.Gas&method=Utilities.Gas.ApiProxy.UpdateOrderRecordsStatus&parameters='

token = 'eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJkYXRhIjoiRENqeTBNRG9yendDWkJiY0VtZDRma0JXcFNiVzBycnVOdlZEcSttNEh4cHNISkhlNjZHakVRZGwvbnJVZkhwVVJsRnBQdVVZZklaamFJb3lrNmpqcVVNaUwzc3poQjlUajg1N1BvU3NpS0ovQ0xKTFRDOVYycWpCdTBCbVVUSjQrT1VLMktRZUxObUpndEN4ZXE1VTZNR3dWT2ZmSEZiZ1QzRVRCdkxTRjBwRENpaFdla2FPcHZXeHFOYjFnb282In0.hUvlZ0mVSqoZzNeLUSsfUWT3XJ7KYbl0teh3XRyo_2A'

parameters = [

    '{"outTradeNo":"909f6972ba3126e1c02f9c6c3a39b69d","statusCode":803}']

time_list = []

class counter():

    def set_flag(self, flag):

        redis_conn = redis.Redis(connection_pool=pool)

        self.flag = flag

        redis_conn.set('counter', flag)

        return 'success'

    def get_flag(self, key):

        redis_conn = redis.Redis(connection_pool=pool)

        self.key = key

        _new_flag = ord(redis_conn.get(self.key))

        print(_new_flag)

        return _new_flag

    def incr_flag(self, key):

        redis_conn = redis.Redis(connection_pool=pool)

        self.key = key

        _new_flag = redis_conn.incr(self.key)

        print('第', _new_flag, '個線程組')

        return _new_flag

class getRequests():

    def __init__(self, url, token, params):

        self.token = token

        self.params = params

        self.url = url+random.choice(params)

        self.headers = {'content-type': 'application/json',

                        'Authorization': 'Bearer '+self.token}

    def get(self):

        try:

            r = requests.get(self.url, timeout=5, headers=self.headers)

            data = r.text

            logger.info(data)

            response_time = r.elapsed.total_seconds()*1000

            time_list.append(response_time)

            print('data:', data)

            time_list.sort(reverse=True)

            # print(time_list)

            sum = 0

            for i in range(len(time_list)):

                sum = sum+time_list[i]

            avg_time = sum/len(time_list)

            print('avg_time:', avg_time)

            print('max_time:', max(time_list))

            print('min_time:', min(time_list))

            print('90%line:', time_list[math.ceil((len(time_list)-1)*0.1)])

            logger.info(avg_time)

        except Exception as err:

            print(err)

            logger.error(err)

def exec():

    result = getRequests(url, token, parameters)

    return result.get()

def open_threads():

    try:

        i = 0

        # 开启{{tasks_number}}個线程

        tasks_number = 5

        while i < tasks_number:

            t = threading.Thread(target=exec)

            t.start()

            i += 1

    except Exception as err:

        print(err)

# {{_delay}秒內開啟{tasks_number}}個線程

_delay = 2

# 每個線程組請求間隔{{_sleep_time}}

_sleep_time = 5

while True:

    count = counter().incr_flag('counter')

    if(count >= 200):

        break

    else:

        timer = threading.Timer(_delay, open_threads)

        timer.start()

        time.sleep(_sleep_time)