feat: Add SSL/TLS support for ClickHouse connections

getsentry · Jan 9, 2025 · f15ec56 · f15ec56
1 parent be3d961
commit f15ec56
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/snuba/clusters/cluster.py b/snuba/clusters/cluster.py
@@ -449,9 +449,9 @@ def get_http_port(self) -> int:
         password=cluster.get("password", ""),
         database=cluster.get("database", "default"),
         http_port=cluster["http_port"],
-        secure=cluster["secure"],
-        ca_certs=cluster["ca_certs"],
-        verify=cluster["verify"],
+        secure=cluster.get("secure", False),
+        ca_certs=cluster.get("ca_certs", None),
+        verify=cluster.get("verify", False),
         storage_sets=cluster["storage_sets"],
         single_node=cluster["single_node"],
         cluster_name=cluster["cluster_name"] if "cluster_name" in cluster else None,
@@ -498,9 +498,9 @@ def _build_sliced_cluster(cluster: Mapping[str, Any]) -> ClickhouseCluster:
         password=cluster.get("password", ""),
         database=cluster.get("database", "default"),
         http_port=cluster["http_port"],
-        secure=cluster["secure"],
-        ca_certs=cluster["ca_certs"],
-        verify=cluster["verify"],
+        secure=cluster.get("secure", False),
+        ca_certs=cluster.get("ca_certs", None),
+        verify=cluster.get("verify", False),
         storage_sets={
             storage_tuple[0] for storage_tuple in cluster["storage_set_slices"]
         },