如何使用 python 中的bulkupdate 更新彈性搜索中的字段。我嘗試了很多方法，但都出錯了。在某些情況下，我收到文檔丟失錯誤，如何同時更新和更新插入。而且附加到字段也不起作用。elasticsearch==7.9.1 是我在 python 中使用的包for i in range(0, length, steps): end_index = length-1 if i+steps>length else i+steps temp_list = test_data[i: end_index] bulk_file = '' actions = [{ "_index": "test-data", "_opt_type":"update", "_type": "test-test-data", "_id": test_row ['testId'], "doc":{"script": { "source": "ctx._source.DataIds.add(params.DataIds)", "lang": "painless", "params": { "DataIds":test_row ['DataIds'] } }} } for test_row in temp_list ] helpers.bulk(es, actions)我得到的錯誤是這樣的 {'update': {'_index': 'test-data', '_type': 'products', '_id': '333', 'status': 400, 'error': {'type': 'illegal_argument_exception', 'reason': 'failed to execute script', 'caused_by': {'type': 'script_exception', 'reason': 'runtime error', 'script_stack': ['ctx._source.dataIds.add(params.dataIds)', ' ^---- HERE'], 'script': 'if (ctx._source.dataIds == null) { ctx._source.dataIds = []; } ctx._source.dataIds.add(params.dataIds)', 'lang': 'painless', 'position': {'offset': 105, 'start': 71, 'end': 118}, 'caused_by': {'type': 'illegal_argument_exception', 'reason': 'dynamic method [java.lang.String, add/1] not found'}}}, 'data': {'upsert': {}, 'scripted_upsert': True, 'script': {'source': 'if (ctx._source.dataIds == null) { ctx._source.dataIds = []; } ctx._source.dataIds.add(params.dataIds)', 'lang': 'painless', 'params': {'cdataIds': 'set123'}}}}}])
使用 python 進行 Elastic Search 批量更新，如何使用新數據追加數組字段
慕的地6264312
2023-10-26 15:14:59
