|
1 | | - |
2 | 1 | import copy |
3 | 2 | import logging |
4 | 3 | from requests import Session |
| 4 | +import urllib3 |
| 5 | +from functools import wraps |
| 6 | +import warnings |
5 | 7 |
|
6 | 8 | log = logging.getLogger(__name__) |
7 | 9 |
|
8 | 10 |
|
| 11 | +def disable_insecure_request_warning(func): |
| 12 | + @wraps(func) |
| 13 | + def wrapper(*args, **kwargs): |
| 14 | + if kwargs.get('verify') is False: |
| 15 | + # store the original filters to restore them after the request |
| 16 | + original_filters = warnings.filters[:] |
| 17 | + # disable the warning for this request |
| 18 | + urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning) |
| 19 | + try: |
| 20 | + return func(*args, **kwargs) |
| 21 | + finally: |
| 22 | + # restore the original filters |
| 23 | + warnings.filters = original_filters |
| 24 | + else: |
| 25 | + return func(*args, **kwargs) |
| 26 | + return wrapper |
| 27 | + |
| 28 | + |
9 | 29 | class CustomSession(Session): |
10 | 30 | def __init__(self, *args, **kwargs): |
11 | 31 | super().__init__(*args, **kwargs) |
12 | 32 | self.default_timeout = 5 |
13 | 33 |
|
| 34 | + @disable_insecure_request_warning |
14 | 35 | def request(self, method, url, *args, **kwargs): |
15 | 36 | kwargs.setdefault('timeout', self.default_timeout) |
16 | 37 | return super().request(method, url, *args, **kwargs) |
|
0 commit comments