in comprehend.py [0:0]
def connectES():
print ('Connecting to the ES Endpoint {0}')
awsauth = AWS4Auth(credentials.access_key,
credentials.secret_key,
region, service,
session_token=credentials.token)
try:
es = Elasticsearch(
hosts=[{'host': host, 'port': 443}],
http_auth = awsauth,
use_ssl=True,
verify_certs=True,
connection_class=RequestsHttpConnection)
return es
except Exception as E:
print("Unable to connect to {0}")
print(E)
exit(3)