Import ledger transactions to local elastic search instance

import

#!/usr/bin/env ruby

require 'csv'
require 'elasticsearch'
require 'securerandom'

file = ARGV.shift

unless file
  warn "Usage: $0 <ledger file>"
  exit 1
end

src = %x{ledger csv -f "#{file}"}

client = Elasticsearch::Client.new log: true
#client.indices.delete index: :ledger

keys = [
  :date,
  :_,
  :txn,
  :account,
  :currency,
  :amount,
  :_,
  :_
]

CSV.parse(src) do |row|
  h = keys.zip(row).to_h
  h[:date] = Date.parse(h[:date])
  h[:account_tags] = h[:account].split(":")
  h[:amount] = h[:amount].to_f
  h.delete(:_)

  client.index index: 'ledger', type: 'txn', id: SecureRandom.uuid, body: h
end