সময় সিরিজ এবং আরও অনেক কিছুর জন্য Vela → স্মার্ট ক্যাশে

ফিনটেক-এ, আমাদের প্রায়ই প্রচুর পরিমাণে মুদ্রা বিনিময় হার ডেটা প্রক্রিয়া করতে হয়। আমরা বিভিন্ন উত্স থেকে ডেটা পাই, এবং তাদের প্রত্যেকের নিজস্ব ধারণা আছে কীভাবে আগামীকাল, পরশু, পরের মাস এবং এমনকি পরবর্তী তিন বছরের বিনিময় হার এক্সট্রাপোলেট করা যায়। যদি কেউ হার ভবিষ্যদ্বাণী করতে পারে সঠিকভাবে, এটা ব্যবসা বন্ধ করার সময় হবে এবং শুধু বোকামি করে টাকা পরিবর্তন করতে হবে। কিছু উত্স আরও নির্ভরযোগ্য, কিছু সম্পূর্ণ আবর্জনা সরবরাহ করে, প্রায় সঠিক মানগুলির বিরল অন্তর্ভুক্তি সহ, তবে বহিরাগত দম্পতিদের জন্য। আমাদের কাজ হল প্রতি সেকেন্ডে এই দশ হাজার মানগুলির মধ্য দিয়ে পরীক্ষা করা এবং গ্রাহকদের ঠিক কী দেখাতে হবে তা নির্ধারণ করা। আমাদের টন ময়লা এবং পলি থেকে একটি সঠিক মান ফিল্টার করতে হবে, ঠিক যেমন ফ্ল্যামিঙ্গোরা লাঞ্চে করে।

ফ্ল্যামিঙ্গোদের একটি বিশেষ স্বতন্ত্র বৈশিষ্ট্য হল তাদের বিশাল নিম্নমুখী বাঁকা চঞ্চু, যার সাহায্যে তারা পানি বা কাদা থেকে খাবার ফিল্টার করে।
 - Vicki

এভাবেই লাইব্রেরির জন্ম হয় 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