如何使用 AWS Lambda 函数访问启用了 VPC 的 Elasticsearch

如何解决如何使用 AWS Lambda 函数访问启用了 VPC 的 Elasticsearch

我正在尝试使用 lambda 函数访问弹性搜索集群。我面临的问题是它给出了一个错误。回复是：

{
  "errorMessage": "Failed to parse: https://[https://vpc-myendpoint-us-east-1.es.amazonaws.com/]:443/_cluster/health","errorType": "InvalidURL","stackTrace": [
    "  File \"/var/task/lambda_function.py\",line 23,in lambda_handler\n    print(es.cluster.health())\n","  File \"/var/task/elasticsearch/client/utils.py\",line 153,in _wrapped\n    return func(*args,params=params,headers=headers,**kwargs)\n","  File \"/var/task/elasticsearch/client/cluster.py\",line 66,in health\n    return self.transport.perform_request(\n","  File \"/var/task/elasticsearch/transport.py\",line 381,in perform_request\n    status,headers_response,data = connection.perform_request(\n","  File \"/var/task/elasticsearch/connection/HTTP_Requests.py\",line 159,in perform_request\n    prepared_request = self.session.prepare_request(request)\n","  File \"/var/task/requests/sessions.py\",line 456,in prepare_request\n    p.prepare(\n","  File \"/var/task/requests/models.py\",line 316,in prepare\n    self.prepare_url(url,params)\n",line 384,in prepare_url\n    raise InvalidURL(*e.args)\n"
  ]
}

我的代码在 python 中，如下所示：

from elasticsearch import Elasticsearch,Requestshttpconnection
from requests_aws4auth import AWS4Auth
import boto3


def lambda_handler(event,context):
    region = 'us-east-1'
    host = 'https://vpc-myendpoint.us-east-1.es.amazonaws.com/'
    service = 'es'
    
    credentials = boto3.Session().get_credentials()
    awsauth = AWS4Auth(credentials.access_key,credentials.secret_key,region,service,session_token=credentials.token)

    es = Elasticsearch(
        hosts=[{'host': host,'port': 443}],http_auth= awsauth,use_ssl=True,verify_certs=True,connection_class=Requestshttpconnection
    )

    print(es.cluster.health())

我该如何解决这个错误。我的猜测是启用 VPC 的端点使用不同的技术来访问。如果是这样，如何访问它们？

提前致谢

解决方法

看错误信息：

“解析失败：https://[https://vpc-myendpoint-us-east-1.es.amazonaws.com/]:443/_cluster/health”，

https://[https://vpc-myendpoint-us-east-1.es.amazonaws.com 不是有效网址。

您正在一个需要主机名的变量中指定一个 URL。

改变这个：

host = 'https://vpc-myendpoint.us-east-1.es.amazonaws.com/'

为此：host = 'vpc-myendpoint.us-east-1.es.amazonaws.com'