Skip to content

Commit

Permalink
back to username+pass
Browse files Browse the repository at this point in the history
  • Loading branch information
chouinar committed Oct 11, 2024
1 parent 34d9b52 commit 6bd7ba8
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions api/src/adapters/search/opensearch_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -268,12 +268,13 @@ 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")
#credentials = boto3.Session().get_credentials()
#auth = opensearchpy.AWSV4SignerAuth(credentials, opensearch_config.aws_region, "es")
auth = (opensearch_config.search_username, opensearch_config.search_password)
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]
#path = f"https://{opensearch_config.search_username}:{opensearch_config.search_password}@{opensearch_config.search_endpoint}:{opensearch_config.search_port}"
#params["hosts"] = [path]

return params

0 comments on commit 6bd7ba8

Please sign in to comment.