diff --git a/pydruid/client.py b/pydruid/client.py index ae51eab7..5a70353b 100755 --- a/pydruid/client.py +++ b/pydruid/client.py @@ -15,6 +15,7 @@ # import json import re +import ssl import urllib from base64 import b64encode @@ -43,6 +44,13 @@ def set_proxies(self, proxies): opener = urllib.request.build_opener(proxy_support) urllib.request.install_opener(opener) + def set_cert_chain(self, certfile, keyfile=None, password=None): + context = ssl.create_default_context() + context.load_cert_chain(certfile, keyfile, password) + handler = urllib.request.HTTPSHandler(context=context) + opener = urllib.request.build_opener(handler) + urllib.request.install_opener(opener) + def _prepare_url_headers_and_body(self, query): querystr = json.dumps(query.query_dict).encode("utf-8") if self.url.endswith("/"): diff --git a/pydruid/db/api.py b/pydruid/db/api.py index 86b64e5e..9b415f9d 100644 --- a/pydruid/db/api.py +++ b/pydruid/db/api.py @@ -204,8 +204,8 @@ def __init__( context=None, header=False, ssl_verify_cert=True, - proxies=None, ssl_client_cert=None, + proxies=None, ): self.url = url self.context = context or {}