最強に雑なmboxデータelasticsearch取り込み

index_mbox.rb

require "bundler/setup"
require "kconv"
Bundler.require

client = Elasticsearch::Client.new log: true

bulk_requests = Array.new

# mbox
mboxes = Mbox.open("./gmail.mbox")
for i in 0..(mboxes.length-1)
  begin
    client.index index: 'gmail', type: 'gmail', id: i,
      body:{
        from: mboxes[i].headers[:from].toutf8,
        to: mboxes[i].headers[:to].toutf8,
        body: mboxes[i].content.first.to_s.toutf8.gsub(/(\r\n|\r|\n|\f)/,""),
        date: DateTime.parse(mboxes[i].headers[:date])
    }
  rescue
    next
  end
end