အချိန်စီးရီးနှင့် အခြားအရာများအတွက် Vela → စမတ် ကက်ရှ်

fintech တွင်၊ ကျွန်ုပ်တို့သည် ငွေကြေးလဲလှယ်မှုနှုန်းဒေတာ၏ ကြီးမားသောပမာဏကို မကြာခဏလုပ်ဆောင်ရန် လိုအပ်သည်။ ကျွန်ုပ်တို့သည် မတူညီသောရင်းမြစ်များမှ ဒေတာကိုရရှိကြပြီး ၎င်းတို့တစ်ဦးစီသည် မနက်ဖြန်၊ သဘက်ခါ၊ နောက်လနှင့် နောက်ထပ်သုံးနှစ်အတွက် ငွေလဲနှုန်းများကို မည်ကဲ့သို့ ပေါင်းထည့်ရမည်ဆိုသည့် ကိုယ်ပိုင်စိတ်ကူးရှိသည်။ နှုန်းထားများကို တစ်စုံတစ်ယောက်ကသာ ခန့်မှန်းနိုင်လျှင် မှန်ကန်စွာ၊ လုပ်ငန်းပိတ်ချိန်ရောက်ပြီ ၊ ငွေအခေါက်ခေါက်အခါခါပြောင်းရုံပါပဲ။ အချို့သောရင်းမြစ်များသည် ပိုမိုယုံကြည်စိတ်ချရပြီး အချို့မှာ မှန်ကန်သောတန်ဖိုးများနီးပါးပါဝင်သည့် ရှားပါးသော အမှိုက်များကို ပြည့်စုံစွာပေးဆောင်သော်လည်း ထူးခြားဆန်းပြားသောစုံတွဲများအတွက်ဖြစ်သည်။ ကျွန်ုပ်တို့၏အလုပ်မှာ တစ်စက္ကန့်လျှင် သောင်းနှင့်ချီသော တန်ဖိုးများကို ခွဲခြမ်းစိပ်ဖြာပြီး ဖောက်သည်များအား ပြသရမည့်အရာကို အတိအကျ ဆုံးဖြတ်ရန်ဖြစ်သည်။ နေ့လယ်စာမှာ Flamingos လုပ်သလိုမျိုး အညစ်အကြေးနဲ့ နုန်းတွေကနေ မှန်ကန်တဲ့တန်ဖိုးတစ်ခုကို စစ်ထုတ်ဖို့လိုပါတယ်။

Flamingos ၏ အထူးထူးခြားချက်မှာ ၎င်းတို့၏ ကြီးမားသော အောက်ပိုင်းကွေးသော နှုတ်သီးဖြစ်ပြီး ၎င်းတို့သည် အစာများကို ရေ သို့မဟုတ် ရွှံ့များမှ စစ်ထုတ်ပေးပါသည်။
 - Vicky

ဒီလိုနဲ့ စာကြည့်တိုက်တွေ ပေါ်ပေါက်လာတယ်။ Velaသတ်မှတ်ထားသောအချိန်ကြားကာလများတွင် တန်ဖိုးများစွာအတွက် state cache တစ်ခုကို သိမ်းဆည်းပေးသည်။ အဖုံးအောက်တွင်၊ ၎င်းသည် ပျံသန်းနေစဉ်အတွင်း ဆိုးရွားပြီး ခေတ်မမီသောဒေတာများကို စစ်ထုတ်ကာ နောက်ဆုံးပေါ်ဝင်ရောက်ခွင့်ကိုလည်း ပေးပါသည်။ 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__ မဟုတ်ရင်၊
• sorting လုပ်လျှင် ဖြစ်စေသည်။ sorter ပေးထားသောသော့အတွက် သတ်မှတ်ထားသော သို့မဟုတ် တန်ဖိုးကို စာရင်း၏ခေါင်းတွင် ရိုးရိုးထားမည် (LIFOအခန်းကိုကြည့်ပါ။ sorting အောက်တွင်);
• ကန့်သတ်ချက်များအရ အတန်းကို ဖြတ်တောက်မည်ဖြစ်သည်။ :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ထို့ကြောင့် သင်သည် တန်ဖိုးများကို အပ်ဒိတ်လုပ်ရန်အတွက် arsenal မှ နက်ရှိုင်းစွာ မွမ်းမံပြင်ဆင်ခြင်းအတွက် စံလုပ်ဆောင်ချက်များကို အသုံးပြုနိုင်သည်။ Kernel: Kernel.get_in/2, Kernel.put_in/3, Kernel.update_in/3, Kernel.pop_in/2နှင့် Kernel.get_and_update_in/3.

အတည်ပြုချက်

အတည်ပြုသူအား အောက်ပါအတိုင်း သတ်မှတ်နိုင်သည်။

• အငြင်းအခုံတစ်ခုဖြင့် ပြင်ပလုပ်ဆောင်ချက် (&MyMod.my_fun/1) ၎င်းသည် အတည်ပြုမှုအတွက်သာ တန်ဖိုးကို ရရှိမည်ဖြစ်သည်။
• အငြင်းအခုံနှစ်ခုဖြင့် ပြင်ပလုပ်ဆောင်ချက်၊ &MyMod.my_fun/2တွဲရလိမ့်မယ်။ serie, value တရားဝင်မှုအတွက်;
• module အကောင်အထည်ဖော်ခြင်း။ Vela.Validator;
• configuration ကန့်သတ်ချက် thresholdနှင့် - ရွေးချယ်နိုင်သည် - compare_byအခန်းကိုကြည့်ပါ။ နှိုင်းယှဉ်မှု အောက်တွင်ဖော်ပြထားသော။

အတည်ပြုခြင်းအောင်မြင်ပါက၊ သက်ဆိုင်သောသော့အောက်တွင် စာရင်းထဲသို့ တန်ဖိုးကို ပေါင်းထည့်သည်၊ သို့မဟုတ်ပါက tuple {serie, value} သွားသည် :__errors_.

နှိုင်းယှဉ်မှု

ဤအတန်းများတွင် သိမ်းဆည်းထားသော တန်ဖိုးများသည် ဘာမဆို ဖြစ်နိုင်သည်။ သင်ကြားရန် Vela ၎င်းတို့ကို နှိုင်းယှဉ်ရန်၊ လွှဲပြောင်းရန် လိုအပ်သည်။ compare_by စီးရီး၏အဓိပ္ပါယ်သတ်မှတ်ချက်များ (တန်ဖိုးများကိုစံနှင့်နှိုင်းယှဉ်၍မရပါက၊ Kernel.</2); ဤသတ်မှတ်ချက်သည် အမျိုးအစားဖြစ်ရမည်။ (Vela.value() -> number()). ပုံမှန်အားဖြင့်၎င်းသည်ရိုးရှင်းသည်။ & &1.

ထို့အပြင်၊ သင်သည် အတန်းသတ်မှတ်မှုသို့ ဘောင်တစ်ခုကို ဖြတ်သန်းနိုင်သည်။ comparator မြစ်ဝကျွန်းပေါ်ဒေသတန်ဖိုးများကို တွက်ချက်ရန် (min/max); ဥပမာအားဖြင့်၊ ထုတ်လွှင့်ခြင်း။ Date.diff/2 နှိုင်းယှဉ်သူအနေဖြင့် ရက်စွဲများအတွက် မှန်ကန်သော deltas ကို သင်ရနိုင်သည်။

အလုပ်လုပ်ရန် နောက်ထပ်အဆင်ပြေသောနည်းလမ်းမှာ ကန့်သတ်ချက်တစ်ခုကို ကျော်ဖြတ်ရန်ဖြစ်သည်။ thresholdအသစ်မှ တန်ဖိုးအသစ်၏ အများဆုံးခွင့်ပြုနိုင်သော အချိုးကို သတ်မှတ်သည်။ {min, max} ကြားကာလ။ ရာခိုင်နှုန်းအဖြစ် သတ်မှတ်ထားသောကြောင့် ချက်လက်မှတ်ကို အသုံးမပြုပါ။ comparatorဒါပေမယ့် သုံးနေတုန်းပဲ။ compare_by. ဥပမာအားဖြင့်၊ ရက်စွဲအချိန်များအတွက် တံခါးခုံတန်ဖိုးကို သတ်မှတ်ရန်၊ သင်သည် သတ်မှတ်ရပါမည်။ compare_by: &DateTime.to_unix/1 (ကိန်းပြည့်တန်ဖိုးကို ရယူရန်) နှင့် threshold: 1အသစ်သောတန်ဖိုးများကိုဖြစ်ပေါ်စေသည်ရှိမှသာခွင့်ပြုပါ။ ±band လက်ရှိတန်ဖိုးများမှ ကြားကာလ။

နောက်ဆုံးအနေနဲ့ သင်အသုံးပြုနိုင်ပါတယ်။ Vela.equal?/2 ကက်ရှ်နှစ်ခုကို နှိုင်းယှဉ်ရန်။ အကယ်၍ တန်ဖိုးများကို function တစ်ခု သတ်မှတ်ပါသည်။ equal?/2 သို့မဟုတ် compare/2ထို့နောက် ဤလုပ်ဆောင်ချက်များကို နှိုင်းယှဉ်ရန်အတွက် အသုံးပြုလိမ့်မည်၊ မဟုတ်ပါက ကျွန်ုပ်တို့သည် မိုက်မဲစွာ အသုံးပြုပါသည်။ ==/2.

တန်ဘိုးများရယူခြင်း။

လက်ရှိအခြေအနေအား လုပ်ဆောင်ခြင်းသည် များသောအားဖြင့် ခေါ်ဆိုခြင်းဖြင့် စတင်သည်။ Vela.purge/1အသုံးမပြုတော့သော တန်ဖိုးများကို ဖယ်ရှားပေးသော (ဆိုပါက validator ချိတ်ထားသည်။ timestamps) ပြီးရင် ဖုန်းဆက်လို့ရတယ်။ Vela.slice/1ဘယ်ပြန်လာမလဲ။ keyword သော့များနှင့် ပထမ၊ အမှန်တကယ်တန်ဖိုးများအဖြစ် အတန်းအမည်များ။

သင်လည်းသုံးနိုင်သည် get_in/2/pop_in/2 low-level access to the values ​​in each row.

လြှောကျလှာ

Vela process state မှာ time series cache အဖြစ် အလွန်အသုံးဝင်ပါတယ်။ GenServer/Agent. ကျွန်ုပ်တို့သည် ဖောက်ပြန်သောသင်တန်းတန်ဖိုးများကို ဘယ်တော့မှအသုံးမပြုလိုပါ၊ ၎င်းကိုလုပ်ဆောင်ရန်အတွက် ကျွန်ုပ်တို့သည် လုပ်ငန်းစဉ်ကို နိုင်ငံတော်အဆင့်ဖြင့် စီမံဆောင်ရွက်ထားရုံသာဖြစ်သည်။ Velaအောက်တွင်ဖော်ပြထားသော validator နှင့်အတူ။

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

и Vela.purge/1 ဒေတာကို လိုအပ်တိုင်း တိတ်တဆိတ် ဖယ်ရှားသည်။ အမှန်တကယ်တန်ဖိုးများကိုရယူရန်ကျွန်ုပ်တို့ရိုးရှင်းစွာခေါ်ဆိုပါ။ Vela.slice/1သင်တန်း၏သမိုင်းကြောင်းအသေးစား (စီးရီးတစ်ခုလုံး) လိုအပ်သောအခါ၊ ကျွန်ုပ်တို့က ၎င်းကို စီထားပြီးသားဖြစ်သည်- မှန်ကန်သောတန်ဖိုးများဖြင့် ပြန်ပေးပါသည်။

• GitHub
• Hexdocs

ပျော်ရွှင်ဖွယ်အချိန်စီးရီး သိမ်းဆည်းခြင်း

source: www.habr.com