സമയ സീരീസിനും അതിലേറെ കാര്യങ്ങൾക്കുമായി Vela → സ്മാർട്ട് കാഷെ

ഫിൻടെക്കിൽ, കറൻസി വിനിമയ നിരക്ക് ഡാറ്റയുടെ വളരെ വലിയ അളവുകൾ ഞങ്ങൾ പലപ്പോഴും പ്രോസസ്സ് ചെയ്യേണ്ടതുണ്ട്. വ്യത്യസ്‌ത സ്രോതസ്സുകളിൽ നിന്ന് ഞങ്ങൾക്ക് ഡാറ്റ ലഭിക്കുന്നു, അവയ്‌ക്ക് ഓരോന്നിനും നാളെ, നാളത്തെ പിറ്റേന്ന്, അടുത്ത മാസം, അടുത്ത മൂന്ന് വർഷത്തേക്കുള്ള വിനിമയ നിരക്കുകൾ എങ്ങനെ എക്‌സ്‌ട്രാപോളേറ്റ് ചെയ്യാം എന്നതിനെക്കുറിച്ച് സ്വന്തം ആശയമുണ്ട്. ആർക്കെങ്കിലും നിരക്കുകൾ പ്രവചിക്കാൻ കഴിയുമെങ്കിൽ ശരി, ബിസിനസ്സ് അവസാനിപ്പിക്കാനും മണ്ടത്തരമായി പണം അങ്ങോട്ടും ഇങ്ങോട്ടും മാറ്റാനുമുള്ള സമയമാണിത്. ചില സ്രോതസ്സുകൾ കൂടുതൽ വിശ്വസനീയമാണ്, ചിലത് പൂർണ്ണമായ മാലിന്യങ്ങൾ വിതരണം ചെയ്യുന്നു, ഏതാണ്ട് ശരിയായ മൂല്യങ്ങളുടെ അപൂർവ ഉൾപ്പെടുത്തലുകൾ, എന്നാൽ വിദേശ ദമ്പതികൾക്ക്. ഒരു സെക്കൻഡിൽ പതിനായിരക്കണക്കിന് മൂല്യങ്ങൾ പരിശോധിച്ച് ഉപഭോക്താക്കൾക്ക് കൃത്യമായി എന്താണ് കാണിക്കേണ്ടതെന്ന് നിർണ്ണയിക്കുക എന്നതാണ് ഞങ്ങളുടെ ജോലി. ഉച്ചഭക്ഷണ സമയത്ത് അരയന്നങ്ങൾ ചെയ്യുന്നതുപോലെ, ടൺ കണക്കിന് അഴുക്കിൽ നിന്നും ചെളിയിൽ നിന്നും നമുക്ക് ശരിയായ മൂല്യം ഫിൽട്ടർ ചെയ്യേണ്ടതുണ്ട്.

അരയന്നങ്ങളുടെ ഒരു പ്രത്യേക സവിശേഷത താഴേയ്‌ക്ക് വളഞ്ഞ വലിയ കൊക്ക് ആണ്, അവ വെള്ളത്തിൽ നിന്നോ ചെളിയിൽ നിന്നോ ഭക്ഷണം ഫിൽട്ടർ ചെയ്യുന്നു.
 - വിക്കി

അങ്ങനെ ലൈബ്രറി പിറന്നു 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, ഒപ്പം Kernel.get_and_update_in/3.

മൂല്യനിർണ്ണയം

ഒരു വാലിഡേറ്ററിനെ ഇങ്ങനെ നിർവചിക്കാം:

• ഒരു ആർഗ്യുമെൻ്റ് ഉള്ള ബാഹ്യ പ്രവർത്തനം (&MyMod.my_fun/1), മൂല്യനിർണ്ണയത്തിനുള്ള മൂല്യം മാത്രമേ ഇതിന് ലഭിക്കൂ;
• രണ്ട് ആർഗ്യുമെൻ്റുകളുള്ള ബാഹ്യ പ്രവർത്തനം, &MyMod.my_fun/2, അവൾക്ക് ഒരു ജോഡി ലഭിക്കും serie, value മൂല്യനിർണ്ണയത്തിനായി;
• മൊഡ്യൂൾ നടപ്പിലാക്കുന്നു Vela.Validator;
• കോൺഫിഗറേഷൻ പരാമീറ്റർ threshold, കൂടാതെ - ഓപ്ഷണലായി - compare_by, അധ്യായം കാണുക താരതമ്യം ചുവടെ.

മൂല്യനിർണ്ണയം വിജയകരമാണെങ്കിൽ, മൂല്യം അനുബന്ധ കീയുടെ കീഴിൽ ലിസ്റ്റിലേക്ക് ചേർക്കും {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, കൂടാതെ കോഴ്‌സിൻ്റെ ഒരു ചെറിയ ചരിത്രം (മുഴുവൻ സീരീസും) ആവശ്യമായി വരുമ്പോൾ, ഞങ്ങൾ അത് സാധൂകരിച്ച മൂല്യങ്ങളോടെ - ഇതിനകം അടുക്കിയിട്ടുള്ള - തിരികെ നൽകും.

• സാമൂഹികം
• ഹെക്സ്ഡോക്സ്

ഹാപ്പി ടൈം സീരീസ് കാഷിംഗ്!

അവലംബം: www.habr.com