Python Elasticsearch客户端更新脚本执行异常排查求助

尝试用Python Elasticsearch客户端给文档的数组字段追加新对象时，触发**RequestError(400, 'illegal_argument_exception', 'failed to execute script')**异常，但用Postman执行相同逻辑的curl请求却能成功插入。使用的Elasticsearch版本为7.17。

尝试的Python代码（两种写法均报错） #

写法1：通过body传递script #

def index_doc(doc_id, index):
    try:
        body = {
            "script": {
                "source": "ctx._source.array_1.add(params.data)",
                "lang": "painless",
                "params": {
                    "data": {
                        "field1": "abc",
                        "field2": 3
                    }
                }
            }
        }

        client.update(
            index=index,
            id=doc_id,
            routing=doc_id,
            body=body
        )
    except Exception as e:
        print("exception - ", doc_id, e)

写法2：单独传递script参数 #

def index_doc(doc_id, index):
    try:
        script = {
            "source": "ctx._source.array_1.add(params.data)",
            "lang": "painless",
            "params": {
                "data": {
                    "field1": "abc",
                    "field2": 3
                }
            }
        }

        client.update(
            index=index,
            id=doc_id,
            routing=doc_id,
            script=script
        )
    except Exception as e:
        print("exception - ", doc_id, e)

可正常执行的curl请求（Postman测试通过） #

curl --location --request POST 'https://<endpoint>/<index_name>/_update/<doc_id>?routing=<doc_id>' \
--header 'Content-Type: application/json' \
--header 'Authorization: Basic <token>' \
--data-raw '{
    "script": {
        "source": "ctx._source.array_1.add(params.data)",
        "lang": "painless",
        "params": {
            "data": {
                "field1": "abc",
                "field2": 3
            }
        }
    }
}'

补充回溯日志 #

exception -  <doc_id> RequestError(400, 'illegal_argument_exception', 'failed to execute script')
Traceback (most recent call last):
  File "/<file_path>", line 137, in index_doc
    client.update(
  File "/Library/Python/3.9/site-packages/elasticsearch/client/utils.py", line 347, in _wrapped
    return func(*args, params=params, headers=headers, **kwargs)
  File "/Library/Python/3.9/site-packages/elasticsearch/client/__init__.py", line 2092, in update
    return self.transport.perform_request(
  File "/Library/Python/3.9/site-packages/elasticsearch/transport.py", line 466, in perform_request
    raise e
  File "/Library/Python/3.9/site-packages/elasticsearch/transport.py", line 427, in perform_request
    status, headers_response, data = connection.perform_request(
  File "/Library/Python/3.9/site-packages/elasticsearch/connection/http_urllib3.py", line 291, in perform_request
    self._raise_error(response.status, raw_data)
  File "/Library/Python/3.9/site-packages/elasticsearch/connection/base.py", line 328, in _raise_error
    raise HTTP_EXCEPTIONS.get(status_code, TransportError)(
elasticsearch.exceptions.RequestError: RequestError(400, 'illegal_argument_exception', 'failed to execute script')

可能的问题原因及解决方法 #

1. Python客户端版本与ES服务端不兼容 #

Elasticsearch客户端与服务端的版本必须严格匹配（大版本一致，小版本尽量接近）。如果使用8.x版本的elasticsearch-py客户端连接7.17的ES服务端，会出现兼容性问题，导致脚本执行失败。

解决方法：
卸载当前客户端，安装与服务端版本一致的7.17.x版本：

pip uninstall elasticsearch
pip install elasticsearch==7.17.0

2. 目标文档中array_1字段未初始化 #

当目标文档不存在array_1数组字段时，直接调用add()方法会触发脚本执行错误。而你用curl测试的文档可能已经存在该数组，因此请求成功。

解决方法：
修改Painless脚本，先判断数组是否存在，不存在则初始化：

# 修改后的script部分
script = {
    "source": """
        if (ctx._source.array_1 == null) {
            ctx._source.array_1 = [];
        }
        ctx._source.array_1.add(params.data)
    """,
    "lang": "painless",
    "params": {
        "data": {
            "field1": "abc",
            "field2": 3
        }
    }
}

3. Python客户端初始化配置缺失 #

curl请求中携带了Authorization认证头，但Python客户端初始化时可能未配置对应的认证参数，导致请求权限不足或请求格式异常。

解决方法：
初始化客户端时添加认证配置，例如：

from elasticsearch import Elasticsearch

client = Elasticsearch(
    "https://<endpoint>",
    http_auth=("<username>", "<password>"),  # 对应Basic认证的账号密码
    verify_certs=True  # 根据实际情况设置是否验证证书
)

4. 脚本参数传递的隐式差异 #

部分版本的Python客户端在传递嵌套参数时，可能存在序列化差异。可以尝试将脚本逻辑改为内联参数的形式（用于排查问题）：

script = {
    "source": "ctx._source.array_1.add({'field1': 'abc', 'field2': 3})",
    "lang": "painless"
}

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