mirror of
https://github.com/zhenxun-org/zhenxun_bot.git
synced 2026-10-03 02:30:01 +08:00
Update http_utils.py
This commit is contained in:
+6
-3
@@ -30,6 +30,7 @@ class AsyncHttpx:
|
|||||||
params: Optional[Dict[str, Any]] = None,
|
params: Optional[Dict[str, Any]] = None,
|
||||||
headers: Optional[Dict[str, str]] = None,
|
headers: Optional[Dict[str, str]] = None,
|
||||||
cookies: Optional[Dict[str, str]] = None,
|
cookies: Optional[Dict[str, str]] = None,
|
||||||
|
verify: bool = True,
|
||||||
use_proxy: bool = True,
|
use_proxy: bool = True,
|
||||||
proxy: Dict[str, str] = None,
|
proxy: Dict[str, str] = None,
|
||||||
timeout: Optional[int] = 30,
|
timeout: Optional[int] = 30,
|
||||||
@@ -50,7 +51,7 @@ class AsyncHttpx:
|
|||||||
if not headers:
|
if not headers:
|
||||||
headers = get_user_agent()
|
headers = get_user_agent()
|
||||||
proxy = proxy if proxy else cls.proxy if use_proxy else None
|
proxy = proxy if proxy else cls.proxy if use_proxy else None
|
||||||
async with httpx.AsyncClient(proxies=proxy) as client:
|
async with httpx.AsyncClient(proxies=proxy,verify=verify) as client:
|
||||||
return await client.get(
|
return await client.get(
|
||||||
url,
|
url,
|
||||||
params=params,
|
params=params,
|
||||||
@@ -68,6 +69,7 @@ class AsyncHttpx:
|
|||||||
data: Optional[Dict[str, str]] = None,
|
data: Optional[Dict[str, str]] = None,
|
||||||
content: Any = None,
|
content: Any = None,
|
||||||
files: Any = None,
|
files: Any = None,
|
||||||
|
verify: bool = True,
|
||||||
use_proxy: bool = True,
|
use_proxy: bool = True,
|
||||||
proxy: Dict[str, str] = None,
|
proxy: Dict[str, str] = None,
|
||||||
json: Optional[Dict[str, Union[Any]]] = None,
|
json: Optional[Dict[str, Union[Any]]] = None,
|
||||||
@@ -96,7 +98,7 @@ class AsyncHttpx:
|
|||||||
if not headers:
|
if not headers:
|
||||||
headers = get_user_agent()
|
headers = get_user_agent()
|
||||||
proxy = proxy if proxy else cls.proxy if use_proxy else None
|
proxy = proxy if proxy else cls.proxy if use_proxy else None
|
||||||
async with httpx.AsyncClient(proxies=proxy) as client:
|
async with httpx.AsyncClient(proxies=proxy,verify=verify) as client:
|
||||||
return await client.post(
|
return await client.post(
|
||||||
url,
|
url,
|
||||||
content=content,
|
content=content,
|
||||||
@@ -117,6 +119,7 @@ class AsyncHttpx:
|
|||||||
path: Union[str, Path],
|
path: Union[str, Path],
|
||||||
*,
|
*,
|
||||||
params: Optional[Dict[str, str]] = None,
|
params: Optional[Dict[str, str]] = None,
|
||||||
|
verify: bool = True,
|
||||||
use_proxy: bool = True,
|
use_proxy: bool = True,
|
||||||
proxy: Dict[str, str] = None,
|
proxy: Dict[str, str] = None,
|
||||||
headers: Optional[Dict[str, str]] = None,
|
headers: Optional[Dict[str, str]] = None,
|
||||||
@@ -169,7 +172,7 @@ class AsyncHttpx:
|
|||||||
headers = get_user_agent()
|
headers = get_user_agent()
|
||||||
proxy = proxy if proxy else cls.proxy if use_proxy else None
|
proxy = proxy if proxy else cls.proxy if use_proxy else None
|
||||||
try:
|
try:
|
||||||
async with httpx.AsyncClient(proxies=proxy) as client:
|
async with httpx.AsyncClient(proxies=proxy,verify=verify) as client:
|
||||||
async with client.stream(
|
async with client.stream(
|
||||||
"GET",
|
"GET",
|
||||||
url,
|
url,
|
||||||
|
|||||||
Reference in New Issue
Block a user