Я пытаюсь перезаписать существующий индекс, потому что у меня те же поля данных, но некоторые значения полей могут измениться, например (состояние заявки: в ожидании -> разрешено, и приоритет также может измениться с 4 -> 3), но количество записей может быть таким же и может быть изменено. поэтому я не могу создавать новый индекс каждый раз, поэтому я просто хочу обновлять данные, при этом каждый раз добавляя их вasticsearch. Можете ли вы помочь мне с этим, пожалуйста?
Я обычно pu sh данные через следующий код в python
documents=df.to_dict(orient='records')
es = Elasticsearch(hosts=['http://localhost:9200'],timeout=600 )
es.indices.delete(index='index_name', ignore=[400, 404])
У меня есть следующие данные в моем датафрейм df
состояние билета sno
- 123 открыто
- 124 разрешено
- 125 в ожидании
в тот же индекс, который я хочу, чтобы мои данные были заменены, как показано в выводе для заявки 123, изменено с открытого на разрешенное
состояние заявки sno
- 123 разрешено
- 124 разрешено
- 125 в ожидании
Заранее спасибо