Python Lambda创建Elasticsearch索引时解析失败报InvalidURL如何解决？

1. 传参格式错误：Elasticsearch Python客户端的host参数仅接受纯域名/IP，不能携带https://等协议前缀。你传入了带HTTPS协议的完整端点地址，客户端拼接请求地址时自动加了默认的http://前缀和端口，最终生成了http://[https://xxx.amazonaws.com/]:9200/example_index的非法URL，直接触发InvalidURL报错。
2. 端口配置错误：AWS托管的Elasticsearch/OpenSearch服务默认对外开放443端口，且强制走HTTPS协议，你配置的9200是ES本地部署的默认端口，不适用于AWS托管场景。
3. 身份验证参数缺失：你代码中生成了AWS4Auth身份验证对象，但未传入Elasticsearch客户端初始化参数，即使地址配置正确也会因为无权限被服务端拒绝。

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

def connect_es(endpoint):
    # 处理AWS ES身份验证
    session = boto3.Session()
    credentials = session.get_credentials()
    awsauth = AWS4Auth(credentials.access_key, credentials.secret_key, session.region_name, 'es',
                       session_token=credentials.token)
    # 移除端点的协议前缀
    pure_host = endpoint.replace("https://", "").replace("http://", "").rstrip("/")
    print(f'Connecting to the ES Endpoint: {pure_host}')
    
    es_client = Elasticsearch(
        hosts=[{"host": pure_host, "port": 443}],
        http_auth=awsauth,
        use_ssl=True,
        verify_certs=True,
        connection_class=RequestsHttpConnection,
        timeout=60
    )
    
    print('Connected to elasticsearch')
    request_body = {
    "settings": {
        "number_of_shards": 5,
        "number_of_replicas": 1
    },
    "mappings": {
        "properties": {
                "address": {
                    "type": "keyword"
                },
                "date_of_birth": {
                    "format": "dateOptionalTime",
                    "type": "date"
                },
                "some_PK": {
                    "type": "keyword"
                },
                "fave_colour": {
                    "type": "text"
                },
                "email_domain": {
                    "type": "keyword"
                }
            }
        }}
    
    print("creating 'example_index' index...")
    es_client.indices.create(index = 'example_index', body = request_body)
    mapping = es_client.indices.get_mapping(index="example_index")

• 原代码中的string字段类型、not_analyzed配置仅适用于Elasticsearch 5.x及更早版本，高版本ES/OpenSearch已废弃上述配置，用keyword类型对应不分词场景、text类型对应分词场景即可，不需要额外配置index参数。
• 建议新增异常捕获逻辑，处理连接失败、索引已存在等异常场景，避免进程直接崩溃。

内容的提问来源于stack exchange，提问作者Hemanth sai