in assets/lambdas/lambdas.py [0:0]
def make_elasticsearch_client(elasticsearch_endpoint):
awsauth = AWSRequestsAuth(
aws_access_key=os.environ['AWS_ACCESS_KEY_ID'],
aws_secret_access_key=os.environ['AWS_SECRET_ACCESS_KEY'],
aws_token=os.environ['AWS_SESSION_TOKEN'],
aws_host=elasticsearch_endpoint,
aws_region=os.environ['AWS_REGION'],
aws_service='es'
)
return Elasticsearch(
hosts=['{0}:443'.format(elasticsearch_endpoint)],
use_ssl=True,
connection_class=RequestsHttpConnection,
http_auth=awsauth
)