CSVファイルからエラスティック検索にデータをインポートする

Question

CSVファイルからエラスティック検索へのカラムのインポートに取り組んでいます。CSVからのエラスティック検索にデータをロードするための正確なクエリと要件を見つけるのに役立ちます。

Answer 1

おそらく、filebeatとlogstashを使用する必要があります。

Filebeatはあなたのcsvファイルを読み、logstashに送信します。

https://www.elastic.co/guide/en/beats/filebeat/current/filebeat-installation.html

Logstashは、あなたのデータを解析し（それはパースをCSVすることができます）とelasticsearchに送信。あなたはこのPythonスクリプトを使用してESにCSVを読み込むことができ

https://www.elastic.co/guide/en/logstash/current/plugins-filters-csv.html

Answer 2

：

Logstashのcsv入力に

import csv 
from elasticsearch import helpers, Elasticsearch 
es = Elasticsearch() 
with open('file.csv') as f: 
    r = csv.DictReader(f) 
    helpers.bulk(es, r, index='index_name', doc_type='doc_type') 

これはelasticsearchするCSVファイル内のすべての行の一括挿入を行います。 100個ほどのアイテムを大量に挿入する場合は、カウンタを作成して一度に100個のアイテムを挿入できます。

PS：Javaの場合は、このライブラリhereをご覧ください。