python有大佬帮帮忙改一下代码吗？

jin920619

学了一下POST，打算并发和循环POST，运行了一下发现太慢了，基本上2秒后接收返回数据后再循环，如何才能实现可以设置并发速度

import requests
while True:
    headers1 = {

}

    json_data1 = {

}




    headers2 = {

    }

    json_data2 = {

    }




    headers3 = {

    }

    json_data3 = {

    }


    headers4 = {

    }

    json_data4 = {

    }


    headers5 = {

    }

    json_data5 = {

    }


    headers6 = {

    }

    json_data6 = {

    }


    headers7 = {

    }

    json_data7 = {
      
    }


    headers8 = {

    }

    json_data8 = {
        
    }


    headers9 = {

    }

    json_data9 = {
        
    }

    response1 = requests.post('1', headers=headers1, json=json_data1)
    response2 = requests.post('1', headers=headers2, json=json_data2)
    response3 = requests.post('1', headers=headers3, json=json_data3)
    response4 = requests.post('1', headers=headers4, json=json_data4)
    response5 = requests.post('1', headers=headers5, json=json_data5)
    response6 = requests.post('1', headers=headers6, json=json_data6)
    response7 = requests.post('1', headers=headers7, json=json_data7)
    response8 = requests.post('1', headers=headers8, json=json_data8)
    response9 = requests.post('1', headers=headers9, json=json_data9)


    print(response1.text)
    print(response2.text)
    print(response3.text)
    print(response4.text)
    print(response5.text)
    print(response6.text)
    print(response7.text)
    print(response8.text)
    print(response9.text)

RichardYangZT

[Python] 纯文本查看 复制代码

import asyncio
import aiohttp

CONCURRENCY = 5

URL = 'https://www.baidu.com'

JSON_DATA = {

}

HEADERS = {

}

semaphore = asyncio.Semaphore(CONCURRENCY)


async def fetch():
    async with semaphore:
        async with aiohttp.ClientSession() as session:
            async with session.post(URL, headers=HEADERS, json=JSON_DATA) as response:
                data =  await response.text()
                print(data)
                return data

async def main():
    tasks = [asyncio.ensure_future(fetch()) for _ in range(10000)]
    return await asyncio.gather(*tasks)
if __name__ == '__main__':
    asyncio.get_event_loop().run_until_complete(main())

CONCURRENCY 是并发数，10000为任务总量，需要python版本3.7以上，依赖协程。
具体请求内容看楼主需要自行修改

choujie1689

[Python] 纯文本查看 复制代码

import requests
def main():
    urls = [
        "https://tenfei05.cfp.cn/creative/vcg/800/new/VCG41560336195.jpg",
        "https://tenfei03.cfp.cn/creative/vcg/800/new/VCG41688057449.jpg",
    ]
    json_data = [
        "nihao",
        "nihao1",
    ]
    headers = [
        "baidu",
        "baidu"
    ]
    
    for url,jsondata,header in zip(urls,json_data,headers):
        response = requests.post(url,jsondata,header)
        print(response.text)
main()

header头部和jsondata如果相同可以只用一个，不行的话，把url，jsondata，header都放在一个list里面，for循环遍历发送请求,如果python3.8以上，可以使用异步请求。看楼主需要