1
我有一個模塊可以將數據保存爲csv格式,這取決於數據大小需要相對較長的時間。 Elixir如何異步完成此任務?我嘗試使用代理,但過程超時。在Elixir中異步運行長時間運行的任務
defmodule FinReporting.Export_CSV do
alias FinReporting.DistributeRepo
alias FinReporting.InterfaceMdl
import Ecto.Query
def start_link do
Agent.start_link(fn -> HashDict.new end, name: __MODULE__)
end
def export do
Agent.update(__MODULE__, fn dict ->
export_sub()
end)
end
defp export_sub do
file = File.open!("test.csv",[:write, :utf8])
IO.puts("===> CSV export of NGInterface file started.")
DistributeRepo.all(from entry in InterfaceMdl, limit: 100000, select: %{ field1: entry.field1, amount: entry.amount})
|>Enum.map(fn(entry)-> %{entry|amount: Decimal.to_string(entry.amount)}end)
|> Enum.map(fn(m) -> [m.field1, m.amount] end)
|> CSV.encode
|> Enum.each(&IO.write(file, &1))
IO.puts("===> CSV export of NGInterface file completed.")
_ = File.close(file)
end
end