Python Elasticsearch

index = 'index_tushare'
body = {
    "mappings": {
        "properties": {
            "ts_code": {
                "type": "keyword"
            },
            "symbol": {
                "type": "keyword"
            },
            "ts_name": {
                "type": "keyword"
            },
            "fullname": {
                "type": "keyword"
            },
            "area": {
                "type": "keyword"
            },
            "industry": {
                "type": "keyword"
            },
            "list_date": {
                "type": "keyword"
            },
            "tab_name": {
                "type": "keyword"
            }
        }
    }
}
# create an index in elasticsearch, ignore status code 400 (index already exists)
es.indices.create(index=index, body=body, ignore=400)

4.创建mapping之后，添加字段

index_daily_close = 'index_daily_close'
body_daily_close = {
    "mappings": {
        "properties": {
            "trade_date": {
                "type": "keyword"
            }
        }
    }
}
es.indices.create(index=index_daily_close, body=body_daily_close, ignore=400)

properties = body_daily_close.get("mappings").get("properties")


def daily_close_add_tscodes(tscode):
    properties.setdefault(tscode, {"type": "keyword"})
    es.indices.put_mapping(index=index_daily_close, body=body_daily_close.get("mappings"))
    print(body_daily_close.get("mappings"))

{
    "error": {
        "root_cause": [
            {
                "type": "illegal_argument_exception",
                "reason": "Limit of total fields [1000] in index [index_daily_close] has been exceeded"
            }
        ],
        "type": "illegal_argument_exception",
        "reason": "Limit of total fields [1000] in index [index_daily_close] has been exceeded"
    },
    "status": 400
}