Elasticsearch批量导入CSV时出现_type参数未知错误求助

问题原因 #

Elasticsearch 7.0及以上版本已完全移除文档类型（_type）概念，默认不再支持在批量请求的元数据中指定_type参数，一旦包含该参数就会触发illegal_argument_exception错误。

解决步骤 #

1. 移除Bulk请求元数据中的_type字段 #

检查你构建批量请求的代码，删除所有包含_type的配置项。
示例修改：
原错误代码（含_type）：

from elasticsearch.helpers import bulk

def generate_actions(csv_data):
    for row in csv_data:
        yield {
            "_index": "your_target_index",
            "_type": "_doc",  # 此行需删除
            "_source": {
                "field1": row["field1"],
                "field2": row["field2"],
                # 其他字段...
            }
        }

bulk(es_client, generate_actions(your_csv_data))

修改后代码：

from elasticsearch.helpers import bulk

def generate_actions(csv_data):
    for row in csv_data:
        yield {
            "_index": "your_target_index",
            "_source": {
                "field1": row["field1"],
                "field2": row["field2"],
                # 其他字段...
            }
        }

bulk(es_client, generate_actions(your_csv_data))

2. 确认Elasticsearch版本 #

执行以下命令验证你的ES实例版本，确保是7.x及以上（该版本开始移除_type）：

curl -XGET 'http://your-es-host:9200/'

返回结果中version.number字段会显示具体版本号。

3. 清理CSV数据中的冗余_type字段 #

如果你的CSV文件本身包含_type列，确保在处理数据时不要将其混入批量请求的元数据中，若无需保留该字段可直接忽略，若需保留则将其作为普通字段放入_source内。

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