🥇वेला → समय श्रृंखला और अधिक के लिए स्मार्ट कैश

फिनटेक में, हमें अक्सर बड़ी मात्रा में मुद्रा विनिमय दर डेटा संसाधित करना पड़ता है। हमें विभिन्न स्रोतों से डेटा मिलता है, और उनमें से प्रत्येक का अपना विचार है कि कल, परसों, अगले महीने और यहां तक कि अगले तीन वर्षों के लिए विनिमय दरों को कैसे बढ़ाया जाए। काश कोई दरों की भविष्यवाणी कर पाता ठीक प्रकार से, यह व्यवसाय बंद करने और मूर्खतापूर्वक पैसे को आगे-पीछे बदलने का समय होगा। कुछ स्रोत अधिक विश्वसनीय हैं, कुछ पूर्ण कचरा प्रदान करते हैं, लगभग सही मूल्यों के दुर्लभ समावेशन के साथ, लेकिन विदेशी जोड़ों के लिए। हमारा काम प्रति सेकंड इन हज़ारों मानों की जांच करना और यह निर्धारित करना है कि ग्राहकों को वास्तव में क्या दिखाना है। हमें टनों गंदगी और गाद में से एक सही मूल्य को फ़िल्टर करने की ज़रूरत है, ठीक वैसे ही जैसे राजहंस दोपहर के भोजन के समय करते हैं।

राजहंस की एक विशेष विशिष्ट विशेषता उनकी विशाल नीचे की ओर मुड़ी हुई चोंच है, जिसकी मदद से वे पानी या कीचड़ से भोजन छानते हैं।
- विकी

इस प्रकार पुस्तकालय का जन्म हुआ 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

वेला → समय श्रृंखला और अधिक के लिए स्मार्ट कैश

मान अद्यतन कर रहा है

मान्यकरण

तुलना

मान प्राप्त करना

अनुप्रयोग

एक टिप्पणी जोड़ें उत्तर रद्द