Vela→時系列のスマートキャッシュだけでなく

フィンテックでは、非常に大量の為替レートデータを処理する必要があります。私たちはさまざまなソースからデータを取得し、それぞれが明日、明後日、翌月、さらには次の3年のレートを推定する方法について独自のアイデアを持っています。誰かがコースを正しく予測する方法を知っている場合、それはビジネスを閉鎖して、愚かにお金を前後に交換するのにちょうどいいでしょう。いくつかの情報源はより信頼できるものであり、いくつかは完全にゴミを供給し、ほとんど正しい値がまれに含まれていますが、エキゾチックなカップル向けです。私たちの仕事は、1秒間にこれらの何万もの値をふるいにかけ、顧客に何を表示するかを決定することです。フラミンゴが夕食時に行うように、私たちは大量の土と沈泥から正しい値だけを取り除く必要があります。



フラミンゴ



フラミンゴの特別な特徴は、巨大な湾曲したくちばしで、水やシルトから食品をろ過する助けになります。

 -  ウィキ

Vela, . , N ( , ).



, . Vela - :



defmodule Pairs do
  use Vela,
    eurusd: [sorter: &Kernel.<=/2],
    eurgbp: [limit: 3, errors: 1],
    eurcad: [validator: Pairs]

  @behaviour Vela.Validator

  @impl Vela.Validator
  def valid?(:eurcad, rate), do: rate > 0
end




Vela.put/3 :



  • validator , (. );
  • , , :__errors__ ;
  • sorter , (LIFO, . );
  • :limit ;
  • Vela.


iex|1 > pairs = %Pairs{}
iex|2 > Vela.put(pairs, :eurcad, 1.0)
#⇒ %Pairs{..., eurcad: [1.0], ...}
iex|3 > Vela.put(pairs, :eurcad, -1.0)
#⇒ %Pairs{__errors__: [eurcad: -1.0], ...}
iex|4 > pairs |> Vela.put(:eurusd, 2.0) |> Vela.put(:eurusd, 1.0)
#⇒ %Pairs{... eurusd: [1.0, 2.0]}


Vela Access, Kernel: Kernel.get_in/2, Kernel.put_in/3, Kernel.update_in/3, Kernel.pop_in/2, and Kernel.get_and_update_in/3.





:



  • (&MyMod.my_fun/1), ;
  • , &MyMod.my_fun/2, serie, value ;
  • , Vela.Validator;
  • threshold,  —  — compare_by, . Comparison .


, , {serie, value} :__errors_.





, , . Vela , compare_by ( Kernel.</2); (Vela.value() -> number()). & &1.



, comparator (min/max); , Date.diff/2 , .



threshold, {min, max} . , comparator, compare_by. , , compare_by: &DateTime.to_unix/1 ( ) threshold: 1, , ±band .



, Vela.equal?/2 . equal?/2 compare/2, , ==/2.





Vela.purge/1, ( validator timestamps). Vela.slice/1, keyword , .



get_in/2/pop_in/2 .





Vela GenServer/Agent. , , Vela, , .



@impl Vela.Validator
def valid?(_key, %Rate{} = rate),
  do: Rate.age(rate) < @death_age


Vela.purge/1 , . Vela.slice/1, ( ),  —  — .








!




All Articles