添加自定义的请求头功能

This commit is contained in:
Jing Ling
2020-08-12 16:45:51 +08:00
parent 0ed89ef595
commit 5eba97ebce
5 changed files with 24 additions and 20 deletions
+4 -3
View File
@@ -182,9 +182,10 @@ class Module(object):
:return: header
"""
# logger.log('DEBUG', f'Get request header')
if settings.enable_fake_header:
return utils.gen_fake_header()
headers = utils.gen_fake_header()
if isinstance(headers, dict):
self.header = headers
return headers
else:
return self.header
+4 -4
View File
@@ -188,8 +188,8 @@ def get_connector():
async def async_request(urls):
results = list()
connector = get_connector()
header = utils.get_random_header()
async with ClientSession(connector=connector, headers=header) as session:
headers = utils.get_random_header()
async with ClientSession(connector=connector, headers=headers) as session:
tasks = []
for i, url in enumerate(urls):
task = asyncio.ensure_future(fetch(session, 'GET', url))
@@ -213,8 +213,8 @@ async def bulk_request(data, port):
logger.log('INFOR', f'Use {method} method to request')
logger.log('INFOR', 'Async subdomains request in progress')
connector = get_connector()
header = utils.get_random_header()
async with ClientSession(connector=connector, headers=header) as session:
headers = utils.get_random_header()
async with ClientSession(connector=connector, headers=headers) as session:
tasks = []
for i, data in enumerate(to_req_data):
url = data.get('url')
+12 -9
View File
@@ -49,21 +49,24 @@ def gen_fake_header():
"""
Generate fake request headers
"""
ua = random.choice(user_agents)
headers = dict()
headers['User-Agent'] = ua
headers.update(settings.headers)
headers = settings.headers
if not isinstance(headers, dict):
headers = dict()
if settings.random_user_agent:
ua = random.choice(user_agents)
headers['User-Agent'] = ua
headers['Accept-Encoding'] = 'gzip, deflate'
return headers
def get_random_header():
"""
Get random proxy
Get random header
"""
header = None
if settings.fake_header:
header = gen_fake_header()
return header
headers = gen_fake_header()
if not isinstance(headers, dict):
headers = None
return headers
def get_random_proxy():