elasticsearchにバルクインサートする時、 データのjson1行につきコマンドのjsonを1行追加しないとならないので。 see also: http://blog.johtani.info/blog/2014/04/24/usage-stream2es/ stream2es だと一気に登録までしてしまうので、 変換の時点で一度確認したかったので書いてみた。 中身は 1行目にヘッダ。 それ以降がデータ。 エスケープなどはRFC4180 っぽい感じ。 "item_id","title","description","price","url","image_url" "11111","たいとる","でぃすくりぷしょん","1000","http://example.com/item/11111","http://example.com/11111.jpg" "22222","たいとる