Trying a different way of passing user/pass

HHS · Oct 11, 2024 · 34d9b52 · 34d9b52
1 parent 8b81deb
commit 34d9b52
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/api/src/adapters/search/opensearch_client.py b/api/src/adapters/search/opensearch_client.py
@@ -268,9 +268,12 @@ def _get_connection_parameters(opensearch_config: OpensearchConfig) -> dict[str,
     # and should connect using the session credentials
     if opensearch_config.search_username and opensearch_config.search_password:
         # Get credentials and authorize with AWS Opensearch Serverless (es)
-        #credentials = boto3.Session().get_credentials()
-        #auth = opensearchpy.AWSV4SignerAuth(credentials, opensearch_config.aws_region, "es")
-        auth = (opensearch_config.search_username, opensearch_config.search_password)
+        credentials = boto3.Session().get_credentials()
+        auth = opensearchpy.AWSV4SignerAuth(credentials, opensearch_config.aws_region, "es")
         params["http_auth"] = auth
 
+        # TODO hacky - do this a better way
+        path = f"https://{opensearch_config.search_username}:{opensearch_config.search_password}@{opensearch_config.search_endpoint}:{opensearch_config.search_port}"
+        params["hosts"] = [path]
+
     return params