समय श्रृंखला र थपको लागि Vela → स्मार्ट क्यास

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

फ्लेमिङ्गोको एउटा विशेष विशेषता भनेको तिनीहरूको ठूलो तलतिर घुमेको चुच्चो हो, जसको साथ तिनीहरूले पानी वा माटोबाट खाना छान्छन्।
 - Wiki

यसरी पुस्तकालयको जन्म भयो 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, र जब पाठ्यक्रमको सानो इतिहास आवश्यक हुन्छ (पूरा श्रृंखला), हामी यसलाई फिर्ता गर्छौं - पहिले नै क्रमबद्ध - मान्य मानहरूसँग।

• GitHub
• हेक्सडोक्स

शुभ समय श्रृंखला क्यासिङ!

स्रोत: www.habr.com