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

নতুন ডেটা টাইপের সমস্ত সুবিধা বোঝার জন্য, চলুন দীর্ঘ-বিদ্যমান রেডিস স্ট্রাকচারগুলিকে দ্রুত দেখে নেওয়া যাক যা রেডিস স্ট্রিমের কার্যকারিতাকে আংশিকভাবে প্রতিলিপি করে।

Redis PUB/SUB

Redis Pub/Sub হল একটি সাধারণ মেসেজিং সিস্টেম যা ইতিমধ্যেই আপনার কী-ভ্যালু স্টোরে তৈরি করা হয়েছে। যাইহোক, সরলতা একটি খরচে আসে:

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

Redis তালিকা

Redis List হল একটি ডেটা স্ট্রাকচার যা রিড কমান্ড ব্লক করাকে সমর্থন করে। আপনি তালিকার শুরু বা শেষ থেকে বার্তা যোগ করতে এবং পড়তে পারেন। এই কাঠামোর উপর ভিত্তি করে, আপনি আপনার বিতরণ করা সিস্টেমের জন্য একটি ভাল স্ট্যাক বা সারি তৈরি করতে পারেন এবং বেশিরভাগ ক্ষেত্রে এটি যথেষ্ট হবে। রেডিস পাব/সাব থেকে প্রধান পার্থক্য:

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

স্ট্রিম পরিচিতি

একটি প্রবাহে একটি এন্ট্রি যোগ করা হচ্ছে৷

টীম XADD স্ট্রীমে একটি নতুন এন্ট্রি যোগ করে। একটি রেকর্ড শুধুমাত্র একটি স্ট্রিং নয়, এটি এক বা একাধিক কী-মান জোড়া নিয়ে গঠিত। সুতরাং, প্রতিটি এন্ট্রি ইতিমধ্যেই কাঠামোবদ্ধ এবং একটি CSV ফাইলের কাঠামোর অনুরূপ।

> XADD mystream * sensor-id 1234 temperature 19.8
1518951480106-0

উপরের উদাহরণে, আমরা নাম (কী) "mystream" সহ স্ট্রীমে দুটি ক্ষেত্র যোগ করি: যথাক্রমে "1234" এবং "19.8" মান সহ "sensor-id" এবং "temperature"। দ্বিতীয় যুক্তি হিসাবে, কমান্ডটি একটি শনাক্তকারী নেয় যা এন্ট্রিতে বরাদ্দ করা হবে - এই শনাক্তকারীটি স্ট্রীমের প্রতিটি এন্ট্রিকে স্বতন্ত্রভাবে সনাক্ত করে। যাইহোক, এই ক্ষেত্রে আমরা * পাস করেছি কারণ আমরা চাই রেডিস আমাদের জন্য একটি নতুন আইডি তৈরি করুক। প্রতিটি নতুন আইডি বাড়বে। অতএব, প্রতিটি নতুন এন্ট্রির পূর্ববর্তী এন্ট্রিগুলির সাথে সম্পর্কিত একটি উচ্চ শনাক্তকারী থাকবে।

শনাক্তকারী বিন্যাস

এন্ট্রি আইডি কমান্ড দ্বারা ফিরে XADD, দুটি অংশ নিয়ে গঠিত:

{millisecondsTime}-{sequenceNumber}
মিলিসেকেন্ড সময় - ইউনিক্স সময় মিলিসেকেন্ডে (রেডিস সার্ভারের সময়)। যাইহোক, যদি বর্তমান সময় আগের রেকর্ডিংয়ের সময়ের তুলনায় একই বা কম হয়, তাহলে পূর্ববর্তী রেকর্ডিংয়ের টাইমস্ট্যাম্প ব্যবহার করা হয়। অতএব, সার্ভারের সময় যদি সময়ের মধ্যে ফিরে যায়, নতুন শনাক্তকারী এখনও বৃদ্ধির সম্পত্তি বজায় রাখবে।

ক্রমিক নম্বর একই মিলিসেকেন্ডে তৈরি রেকর্ডের জন্য ব্যবহার করা হয়। ক্রমিক নম্বর পূর্ববর্তী এন্ট্রির তুলনায় 1 দ্বারা বৃদ্ধি করা হবে। কারন ক্রমিক নম্বর আকারে 64 বিট, তাহলে অনুশীলনে আপনার রেকর্ডের সংখ্যার একটি সীমার মধ্যে চালানো উচিত নয় যা এক মিলিসেকেন্ডের মধ্যে তৈরি করা যেতে পারে।

এই ধরনের শনাক্তকারীর বিন্যাস প্রথম নজরে অদ্ভুত বলে মনে হতে পারে। একজন অবিশ্বাসী পাঠক ভাবতে পারেন কেন সময় শনাক্তকারীর অংশ। কারণ হল Redis স্ট্রিম আইডি দ্বারা পরিসীমা প্রশ্ন সমর্থন করে। যেহেতু শনাক্তকারী রেকর্ডটি তৈরি করার সময়ের সাথে যুক্ত, তাই এটি সময় ব্যাপ্তি অনুসন্ধান করা সম্ভব করে। আমরা কমান্ড তাকান যখন আমরা একটি নির্দিষ্ট উদাহরণ তাকান হবে এক্সরেঞ্জ.

যদি কোনও কারণে ব্যবহারকারীকে তার নিজস্ব শনাক্তকারী নির্দিষ্ট করতে হয়, যা, উদাহরণস্বরূপ, কিছু বাহ্যিক সিস্টেমের সাথে যুক্ত, তাহলে আমরা এটিকে কমান্ডে প্রেরণ করতে পারি XADD নীচে দেখানো হিসাবে * এর পরিবর্তে:

> XADD somestream 0-1 field value
0-1
> XADD somestream 0-2 foo bar
0-2

দয়া করে মনে রাখবেন যে এই ক্ষেত্রে আপনাকে অবশ্যই আইডি বৃদ্ধির উপর নজর রাখতে হবে। আমাদের উদাহরণে, ন্যূনতম শনাক্তকারী হল "0-1", তাই কমান্ডটি "0-1" এর সমান বা কম অন্য শনাক্তকারী গ্রহণ করবে না।

> XADD somestream 0-1 foo bar
(error) ERR The ID specified in XADD is equal or smaller than the target stream top item

স্ট্রীম প্রতি রেকর্ড সংখ্যা

কমান্ড ব্যবহার করে একটি স্ট্রীমে রেকর্ডের সংখ্যা পাওয়া সম্ভব XLEN. আমাদের উদাহরণের জন্য, এই কমান্ডটি নিম্নলিখিত মান প্রদান করবে:

> XLEN somestream
(integer) 2

পরিসরের প্রশ্ন - XRANGE এবং XREVRANGE

পরিসর অনুসারে ডেটা অনুরোধ করতে, আমাদের দুটি শনাক্তকারী নির্দিষ্ট করতে হবে - ব্যাপ্তির শুরু এবং শেষ। ফিরে আসা পরিসীমা সীমানা সহ সমস্ত উপাদান অন্তর্ভুক্ত করবে। এছাড়াও দুটি বিশেষ শনাক্তকারী "-" এবং "+" রয়েছে, যার অর্থ যথাক্রমে স্ট্রীমের সবচেয়ে ছোট (প্রথম রেকর্ড) এবং বৃহত্তম (শেষ রেকর্ড) শনাক্তকারী৷ নীচের উদাহরণটি সমস্ত স্ট্রিম এন্ট্রি তালিকাভুক্ত করবে।

> XRANGE mystream - +
1) 1) 1518951480106-0
   2) 1) "sensor-id"
      2) "1234"
      3) "temperature"
      4) "19.8"
2) 1) 1518951482479-0
   2) 1) "sensor-id"
      2) "9999"
      3) "temperature"
      4) "18.2"

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

> XRANGE mystream 1518951480106 1518951480107
1) 1) 1518951480106-0
   2) 1) "sensor-id"
      2) "1234"
      3) "temperature"
      4) "19.8"

এই পরিসরে আমাদের শুধুমাত্র একটি এন্ট্রি আছে, তবে প্রকৃত ডেটা সেটে ফলাফলটি বিশাল হতে পারে। এই কারনে এক্সরেঞ্জ COUNT বিকল্প সমর্থন করে। পরিমাণ নির্দিষ্ট করে, আমরা সহজভাবে প্রথম N রেকর্ড পেতে পারি। যদি আমাদের পরবর্তী এন রেকর্ড (পৃষ্ঠা সংখ্যা) পেতে হয়, আমরা শেষ প্রাপ্ত আইডি ব্যবহার করতে পারি, এটি বাড়াতে পারি ক্রমিক নম্বর একটি দ্বারা এবং আবার জিজ্ঞাসা. আসুন নিম্নলিখিত উদাহরণে এটি দেখুন। আমরা সঙ্গে 10 উপাদান যোগ করা শুরু XADD (ধরে নিচ্ছি যে মাইস্ট্রিম ইতিমধ্যে 10 টি উপাদানে ভরা ছিল)। প্রতি কমান্ডে 2টি উপাদান পেতে পুনরাবৃত্তি শুরু করতে, আমরা পূর্ণ পরিসর দিয়ে শুরু করি কিন্তু COUNT এর সমান 2 দিয়ে।

> XRANGE mystream - + COUNT 2
1) 1) 1519073278252-0
   2) 1) "foo"
      2) "value_1"
2) 1) 1519073279157-0
   2) 1) "foo"
      2) "value_2"

পরবর্তী দুটি উপাদানের সাথে পুনরাবৃত্তি চালিয়ে যেতে, আমাদের প্রাপ্ত শেষ আইডিটি নির্বাচন করতে হবে, যেমন 1519073279157-0, এবং 1 যোগ করুন ক্রমিক নম্বর.
ফলাফল আইডি, এই ক্ষেত্রে 1519073279157-1, এখন পরবর্তী কলের জন্য রেঞ্জ আর্গুমেন্টের নতুন শুরু হিসাবে ব্যবহার করা যেতে পারে এক্সরেঞ্জ:

> XRANGE mystream 1519073279157-1 + COUNT 2
1) 1) 1519073280281-0
   2) 1) "foo"
      2) "value_3"
2) 1) 1519073281432-0
   2) 1) "foo"
      2) "value_4"

ইত্যাদি। কারণ জটিলতা এক্সরেঞ্জ অনুসন্ধানের জন্য O(log(N)) এবং তারপর O(M) M উপাদানগুলি ফেরত দিতে, তারপর প্রতিটি পুনরাবৃত্তি পদক্ষেপ দ্রুত। এইভাবে, ব্যবহার করে এক্সরেঞ্জ স্ট্রীমগুলি দক্ষতার সাথে পুনরাবৃত্তি করা যেতে পারে।

টীম XREVRANGE সমতুল্য এক্সরেঞ্জ, কিন্তু বিপরীত ক্রমে উপাদান প্রদান করে:

> XREVRANGE mystream + - COUNT 1
1) 1) 1519073287312-0
   2) 1) "foo"
      2) "value_10"

অনুগ্রহ করে নোট করুন যে কমান্ড XREVRANGE রেঞ্জ আর্গুমেন্ট শুরু এবং স্টপ বিপরীত ক্রমে নেয়।

XREAD ব্যবহার করে নতুন এন্ট্রি পড়া

প্রায়শই কাজটি একটি স্ট্রীমে সাবস্ক্রাইব করা এবং শুধুমাত্র নতুন বার্তা গ্রহণ করা হয়। এই ধারণাটি Redis Pub/Sub বা Redis তালিকা ব্লক করার মতো মনে হতে পারে, কিন্তু Redis স্ট্রিম কীভাবে ব্যবহার করতে হয় তার মধ্যে মৌলিক পার্থক্য রয়েছে:

প্রতিটি নতুন বার্তা ডিফল্টরূপে প্রতিটি গ্রাহকের কাছে বিতরণ করা হয়। এই আচরণটি একটি ব্লক করা Redis তালিকা থেকে ভিন্ন, যেখানে একটি নতুন বার্তা শুধুমাত্র একজন গ্রাহকই পড়বেন।
Redis Pub/Sub-এ থাকাকালীন সমস্ত বার্তাগুলি ভুলে যাওয়া হয় এবং কখনও স্থায়ী হয় না, স্ট্রীমে সমস্ত বার্তা অনির্দিষ্টকালের জন্য ধরে রাখা হয় (যদি না ক্লায়েন্ট স্পষ্টভাবে মুছে দেয়)।
রেডিস স্ট্রিম আপনাকে একটি স্ট্রীমের মধ্যে বার্তাগুলিতে অ্যাক্সেসের পার্থক্য করতে দেয়। একটি নির্দিষ্ট গ্রাহক শুধুমাত্র তাদের ব্যক্তিগত বার্তা ইতিহাস দেখতে পারেন.

আপনি একটি থ্রেড সাবস্ক্রাইব করতে পারেন এবং কমান্ড ব্যবহার করে নতুন বার্তা পেতে পারেন XREAD. এটার চেয়ে একটু বেশি জটিল এক্সরেঞ্জ, তাই আমরা প্রথমে সহজ উদাহরণ দিয়ে শুরু করব।

> XREAD COUNT 2 STREAMS mystream 0
1) 1) "mystream"
   2) 1) 1) 1519073278252-0
         2) 1) "foo"
            2) "value_1"
      2) 1) 1519073279157-0
         2) 1) "foo"
            2) "value_2"

উপরের উদাহরণটি একটি নন-ব্লকিং ফর্ম দেখায় XREAD. মনে রাখবেন যে COUNT বিকল্পটি ঐচ্ছিক। প্রকৃতপক্ষে, শুধুমাত্র প্রয়োজনীয় কমান্ড বিকল্পটি হল স্ট্রীমস বিকল্প, যা সংশ্লিষ্ট সর্বাধিক শনাক্তকারীর সাথে স্ট্রিমগুলির একটি তালিকা নির্দিষ্ট করে। আমরা "স্ট্রিমস মাইস্ট্রিম 0" লিখেছি - আমরা "0-0" এর চেয়ে বেশি একটি শনাক্তকারী সহ মাইস্ট্রিম স্ট্রিমের সমস্ত রেকর্ড পেতে চাই। যেমন আপনি উদাহরণ থেকে দেখতে পাচ্ছেন, কমান্ডটি থ্রেডের নাম প্রদান করে কারণ আমরা একই সময়ে একাধিক থ্রেড সাবস্ক্রাইব করতে পারি। আমরা লিখতে পারি, উদাহরণস্বরূপ, "স্ট্রিমস মাইস্ট্রিম অন্যধারা 0 0"। অনুগ্রহ করে মনে রাখবেন যে স্ট্রীমস বিকল্পের পরে আমাদের প্রথমে সমস্ত প্রয়োজনীয় স্ট্রিমগুলির নাম এবং শুধুমাত্র তারপর শনাক্তকারীদের একটি তালিকা প্রদান করতে হবে৷

এই সাধারণ ফর্মে কমান্ডের তুলনায় বিশেষ কিছু করে না এক্সরেঞ্জ. তবে মজার ব্যাপার হল আমরা সহজেই ঘুরতে পারি XREAD একটি ব্লকিং কমান্ডে, ব্লক আর্গুমেন্ট নির্দিষ্ট করে:

> XREAD BLOCK 0 STREAMS mystream $
উপরের উদাহরণে, একটি নতুন ব্লক বিকল্প 0 মিলিসেকেন্ডের টাইমআউটের সাথে নির্দিষ্ট করা হয়েছে (এর মানে অনির্দিষ্টকালের জন্য অপেক্ষা করা)। তাছাড়া, মাইস্ট্রিম স্ট্রীমের জন্য সাধারণ শনাক্তকারী পাস করার পরিবর্তে, একটি বিশেষ শনাক্তকারী $ পাস করা হয়েছিল। এই বিশেষ শনাক্তকারী মানে যে XREAD শনাক্তকারী হিসাবে mystream-এ সর্বাধিক শনাক্তকারী ব্যবহার করতে হবে। তাই আমরা শুনতে শুরু করার মুহূর্ত থেকে শুরু করে শুধুমাত্র নতুন বার্তা পাব। কিছু উপায়ে এটি ইউনিক্স "tail -f" কমান্ডের অনুরূপ।

নোট করুন যে ব্লক বিকল্পটি ব্যবহার করার সময় আমাদের অগত্যা বিশেষ শনাক্তকারী $ ব্যবহার করার প্রয়োজন নেই। আমরা স্ট্রীমে বিদ্যমান যেকোনো শনাক্তকারী ব্যবহার করতে পারি। যদি দলটি ব্লক না করে অবিলম্বে আমাদের অনুরোধটি পরিবেশন করতে পারে, তবে এটি তা করবে, অন্যথায় এটি ব্লক করবে।

ব্লকিং XREAD একই সাথে একাধিক থ্রেডও শুনতে পারেন, আপনাকে শুধু তাদের নাম উল্লেখ করতে হবে। এই ক্ষেত্রে, কমান্ডটি ডেটা প্রাপ্ত প্রথম স্ট্রীমের একটি রেকর্ড ফিরিয়ে দেবে। প্রদত্ত থ্রেডের জন্য ব্লক করা প্রথম গ্রাহক প্রথমে ডেটা পাবেন।

কনজিউমার গ্রুপ

নির্দিষ্ট কিছু কাজে, আমরা একটি থ্রেডের মধ্যে বার্তাগুলিতে গ্রাহকদের অ্যাক্সেস সীমিত করতে চাই। একটি উদাহরণ যেখানে এটি কার্যকর হতে পারে তা হল কর্মীদের সাথে একটি বার্তা সারি যা একটি থ্রেড থেকে বিভিন্ন বার্তা পাবে, বার্তা প্রক্রিয়াকরণকে স্কেল করার অনুমতি দেয়।

যদি আমরা কল্পনা করি যে আমাদের তিনটি গ্রাহক C1, C2, C3 এবং একটি থ্রেড রয়েছে যাতে 1, 2, 3, 4, 5, 6, 7 বার্তা রয়েছে, তাহলে বার্তাগুলি নীচের চিত্রের মতো পরিবেশন করা হবে:

1 -> C1 2 -> C2 3 -> C3 4 -> C1 5 -> C2 6 -> C3 7 -> C1
এই প্রভাব অর্জনের জন্য, রেডিস স্ট্রিম কনজিউমার গ্রুপ নামে একটি ধারণা ব্যবহার করে। এই ধারণাটি একটি ছদ্ম-সাবস্ক্রাইবার অনুরূপ, যেটি একটি স্ট্রীম থেকে ডেটা গ্রহণ করে, কিন্তু প্রকৃতপক্ষে একটি গ্রুপের মধ্যে একাধিক গ্রাহক দ্বারা পরিবেশিত হয়, নির্দিষ্ট গ্যারান্টি প্রদান করে:

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

এক অর্থে, গ্রুপের অবস্থা নিম্নরূপ প্রকাশ করা যেতে পারে:

+----------------------------------------+
| consumer_group_name: mygroup          
| consumer_group_stream: somekey        
| last_delivered_id: 1292309234234-92    
|                                                           
| consumers:                                          
|    "consumer-1" with pending messages  
|       1292309234234-4                          
|       1292309234232-8                          
|    "consumer-42" with pending messages 
|       ... (and so forth)                             
+----------------------------------------+

এখন কনজিউমার গ্রুপের প্রধান কমান্ডগুলির সাথে পরিচিত হওয়ার সময় এসেছে, যথা:

XGROUP গ্রুপ তৈরি, ধ্বংস এবং পরিচালনা করতে ব্যবহৃত হয়
XREADGROUP গ্রুপের মাধ্যমে স্ট্রিম পড়তে ব্যবহৃত
XACK - এই কমান্ডটি গ্রাহককে বার্তাটিকে সফলভাবে প্রক্রিয়াকৃত হিসাবে চিহ্নিত করতে দেয়৷

কনজিউমার গ্রুপ গঠন

ধরা যাক যে mystream ইতিমধ্যেই বিদ্যমান। তারপর গ্রুপ তৈরি কমান্ডটি দেখতে হবে:

> XGROUP CREATE mystream mygroup $ OK
একটি গ্রুপ তৈরি করার সময়, আমাদের অবশ্যই একটি শনাক্তকারী পাস করতে হবে, যেখান থেকে গ্রুপটি বার্তা পাবে। আমরা যদি সব নতুন বার্তা পেতে চাই, তাহলে আমরা বিশেষ শনাক্তকারী $ ব্যবহার করতে পারি (উপরের আমাদের উদাহরণে)। আপনি যদি একটি বিশেষ শনাক্তকারীর পরিবর্তে 0 উল্লেখ করেন, তাহলে থ্রেডের সমস্ত বার্তা গ্রুপে উপলব্ধ হবে।

এখন যে গ্রুপটি তৈরি হয়েছে, আমরা অবিলম্বে কমান্ড ব্যবহার করে বার্তা পড়া শুরু করতে পারি XREADGROUP. এই আদেশটি খুব অনুরূপ XREAD এবং ঐচ্ছিক ব্লক বিকল্প সমর্থন করে। যাইহোক, একটি প্রয়োজনীয় GROUP বিকল্প রয়েছে যা সর্বদা দুটি আর্গুমেন্টের সাথে নির্দিষ্ট করা আবশ্যক: গোষ্ঠীর নাম এবং গ্রাহকের নাম৷ COUNT বিকল্পটিও সমর্থিত।

থ্রেডটি পড়ার আগে, এখানে কিছু বার্তা দেওয়া যাক:

> XADD mystream * message apple
1526569495631-0
> XADD mystream * message orange
1526569498055-0
> XADD mystream * message strawberry
1526569506935-0
> XADD mystream * message apricot
1526569535168-0
> XADD mystream * message banana
1526569544280-0

এখন গ্রুপের মাধ্যমে এই স্ট্রিমটি পড়ার চেষ্টা করা যাক:

> XREADGROUP GROUP mygroup Alice COUNT 1 STREAMS mystream >
1) 1) "mystream"
   2) 1) 1) 1526569495631-0
         2) 1) "message"
            2) "apple"

উপরের কমান্ডটি নিম্নরূপ verbatim পড়ে:

"আমি, সাবস্ক্রাইবার অ্যালিস, মাইগ্রুপের একজন সদস্য, আমার স্ট্রিম থেকে এমন একটি বার্তা পড়তে চাই যা আগে কাউকে দেওয়া হয়নি।"

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

এছাড়াও, বিশেষ ক্ষেত্রে, আপনি একটি বাস্তব শনাক্তকারী যেমন 0 বা অন্য কোনো বৈধ শনাক্তকারী নির্দিষ্ট করতে পারেন। এই ক্ষেত্রে কমান্ড XREADGROUP আপনাকে "মুলতুবি" স্থিতি সহ বার্তাগুলির একটি ইতিহাস ফেরত দেবে যা নির্দিষ্ট গ্রাহকের (এলিস) কাছে বিতরণ করা হয়েছিল কিন্তু কমান্ড ব্যবহার করে এখনও স্বীকার করা হয়নি XACK.

আমরা বিকল্প ছাড়াই অবিলম্বে আইডি 0 উল্লেখ করে এই আচরণটি পরীক্ষা করতে পারি COUNT টি. আমরা কেবল একটি একক মুলতুবি বার্তা দেখতে পাব, সেটি হল, আপেল বার্তা:

> XREADGROUP GROUP mygroup Alice STREAMS mystream 0
1) 1) "mystream"
   2) 1) 1) 1526569495631-0
         2) 1) "message"
            2) "apple"

যাইহোক, যদি আমরা বার্তাটি সফলভাবে প্রক্রিয়াকৃত হিসাবে নিশ্চিত করি, তাহলে এটি আর প্রদর্শিত হবে না:

> XACK mystream mygroup 1526569495631-0
(integer) 1
> XREADGROUP GROUP mygroup Alice STREAMS mystream 0
1) 1) "mystream"
   2) (empty list or set)

এখন ববের কিছু পড়ার পালা:

> XREADGROUP GROUP mygroup Bob COUNT 2 STREAMS mystream >
1) 1) "mystream"
   2) 1) 1) 1526569498055-0
         2) 1) "message"
            2) "orange"
      2) 1) 1526569506935-0
         2) 1) "message"
            2) "strawberry"

বব, মাইগ্রুপের একজন সদস্য, দুইটির বেশি বার্তার জন্য অনুরোধ করেছিলেন। কমান্ডটি শুধুমাত্র বিশেষ শনাক্তকারীর কারণে অবিলম্বিত বার্তাগুলি রিপোর্ট করে ">"৷ আপনি দেখতে পাচ্ছেন, "আপেল" বার্তাটি প্রদর্শিত হবে না যেহেতু এটি ইতিমধ্যে অ্যালিসের কাছে বিতরণ করা হয়েছে, তাই বব "কমলা" এবং "স্ট্রবেরি" গ্রহণ করে।

এইভাবে, অ্যালিস, বব এবং গ্রুপের অন্য কোনো গ্রাহক একই স্ট্রিম থেকে বিভিন্ন বার্তা পড়তে পারবেন। তারা তাদের অপ্রক্রিয়াজাত বার্তাগুলির ইতিহাস পড়তে পারে বা প্রক্রিয়াকৃত বার্তাগুলিকে চিহ্নিত করতে পারে।

মনে রাখতে কিছু জিনিস আছে:

যত তাড়াতাড়ি গ্রাহক বার্তাটিকে একটি আদেশ হিসাবে বিবেচনা করে XREADGROUP, এই বার্তাটি "মুলতুবি" অবস্থায় যায় এবং সেই নির্দিষ্ট গ্রাহককে বরাদ্দ করা হয়। অন্য গ্রুপ গ্রাহকরা এই বার্তা পড়তে সক্ষম হবে না.
সাবস্ক্রাইবার প্রথম উল্লেখ করার পরে স্বয়ংক্রিয়ভাবে তৈরি হয়, তাদের স্পষ্টভাবে তৈরি করার প্রয়োজন নেই।
এর সাহায্যে XREADGROUP আপনি একই সময়ে একাধিক ভিন্ন থ্রেড থেকে বার্তা পড়তে পারেন, তবে এটি কাজ করার জন্য আপনাকে প্রথমে প্রতিটি থ্রেড ব্যবহার করে একই নামের সাথে গ্রুপ তৈরি করতে হবে XGROUP

ব্যর্থতা পুনরুদ্ধার

গ্রাহক ব্যর্থতা থেকে পুনরুদ্ধার করতে পারেন এবং "মুলতুবি" স্থিতি সহ তার বার্তাগুলির তালিকা পুনরায় পড়তে পারেন। যাইহোক, বাস্তব জগতে, গ্রাহকরা শেষ পর্যন্ত ব্যর্থ হতে পারে। একজন গ্রাহকের আটকে থাকা বার্তাগুলির কী হবে যদি গ্রাহক ব্যর্থতা থেকে পুনরুদ্ধার করতে না পারেন?
কনজিউমার গ্রুপ এমন একটি বৈশিষ্ট্য অফার করে যা শুধুমাত্র এই ধরনের ক্ষেত্রে ব্যবহৃত হয় - যখন আপনাকে বার্তাগুলির মালিক পরিবর্তন করতে হবে।

আপনাকে প্রথমে যা করতে হবে তা হল কমান্ডটি কল করুন XPENDING, যা "মুলতুবি" অবস্থা সহ গ্রুপের সমস্ত বার্তা প্রদর্শন করে। এর সহজতম ফর্মে, কমান্ডটিকে শুধুমাত্র দুটি আর্গুমেন্ট দিয়ে বলা হয়: থ্রেডের নাম এবং গ্রুপের নাম:

> XPENDING mystream mygroup
1) (integer) 2
2) 1526569498055-0
3) 1526569506935-0
4) 1) 1) "Bob"
      2) "2"

দলটি সমগ্র গোষ্ঠী এবং প্রতিটি গ্রাহকের জন্য অপ্রক্রিয়াজাত বার্তাগুলির সংখ্যা প্রদর্শন করেছে৷ আমাদের কাছে কেবল দুটি অসামান্য বার্তা সহ বব রয়েছে কারণ অ্যালিসের অনুরোধ করা একমাত্র বার্তাটি নিশ্চিত করা হয়েছিল XACK.

আমরা আরও যুক্তি ব্যবহার করে আরও তথ্যের জন্য অনুরোধ করতে পারি:

XPENDING {key} {groupname} [{start-id} {end-id} {count} [{consumer-name}]]
{start-id} {end-id} - শনাক্তকারীর পরিসর (আপনি "-" এবং "+" ব্যবহার করতে পারেন)
{count} — ডেলিভারি প্রচেষ্টার সংখ্যা
{consumer-name} - গ্রুপের নাম

> XPENDING mystream mygroup - + 10
1) 1) 1526569498055-0
   2) "Bob"
   3) (integer) 74170458
   4) (integer) 1
2) 1) 1526569506935-0
   2) "Bob"
   3) (integer) 74170458
   4) (integer) 1

এখন আমাদের কাছে প্রতিটি বার্তার বিশদ বিবরণ রয়েছে: আইডি, গ্রাহকের নাম, মিলিসেকেন্ডে নিষ্ক্রিয় সময় এবং অবশেষে বিতরণ প্রচেষ্টার সংখ্যা। আমাদের কাছে ববের থেকে দুটি বার্তা রয়েছে এবং সেগুলি 74170458 মিলিসেকেন্ড, প্রায় 20 ঘন্টা ধরে নিষ্ক্রিয় ছিল৷

দয়া করে মনে রাখবেন যে বার্তাটির বিষয়বস্তুটি কেবল ব্যবহার করে কী ছিল তা পরীক্ষা করতে কেউ আমাদের বাধা দিচ্ছে না এক্সরেঞ্জ.

> XRANGE mystream 1526569498055-0 1526569498055-0
1) 1) 1526569498055-0
   2) 1) "message"
      2) "orange"

আমাদের শুধু আর্গুমেন্টে একই শনাক্তকারীকে দুবার পুনরাবৃত্তি করতে হবে। এখন যেহেতু আমাদের কিছু ধারণা আছে, অ্যালিস সিদ্ধান্ত নিতে পারে যে 20 ঘন্টা ডাউনটাইম পরে, বব সম্ভবত পুনরুদ্ধার করবে না, এবং সেই বার্তাগুলিকে জিজ্ঞাসা করার এবং ববের জন্য সেগুলি পুনরায় প্রক্রিয়া করা শুরু করার সময় এসেছে৷ এর জন্য আমরা কমান্ড ব্যবহার করি XCLAIM:

XCLAIM {key} {group} {consumer} {min-idle-time} {ID-1} {ID-2} ... {ID-N}
এই কমান্ডটি ব্যবহার করে, আমরা একটি "বিদেশী" বার্তা পেতে পারি যা মালিককে {উপভোক্তা} এ পরিবর্তন করে এখনও প্রক্রিয়া করা হয়নি৷ যাইহোক, আমরা একটি ন্যূনতম নিষ্ক্রিয় সময় {min-idle-time} প্রদান করতে পারি। এটি এমন পরিস্থিতি এড়াতে সাহায্য করে যেখানে দুটি ক্লায়েন্ট একই সাথে একই বার্তাগুলির মালিক পরিবর্তন করার চেষ্টা করে:

Client 1: XCLAIM mystream mygroup Alice 3600000 1526569498055-0 Clinet 2: XCLAIM mystream mygroup Lora 3600000 1526569498055-0
প্রথম গ্রাহক ডাউনটাইম রিসেট করবে এবং ডেলিভারি কাউন্টার বাড়াবে। তাই দ্বিতীয় ক্লায়েন্ট এটি অনুরোধ করতে সক্ষম হবে না.

> XCLAIM mystream mygroup Alice 3600000 1526569498055-0
1) 1) 1526569498055-0
   2) 1) "message"
      2) "orange"

বার্তাটি সফলভাবে অ্যালিসের দ্বারা দাবি করা হয়েছিল, যিনি এখন বার্তাটি প্রক্রিয়া করতে পারেন এবং এটি স্বীকার করতে পারেন৷

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

ডেলিভারি কাউন্টার

কাউন্টার আপনি আউটপুট দেখতে XPENDING প্রতিটি বার্তা বিতরণের সংখ্যা। এই ধরনের একটি কাউন্টার দুটি উপায়ে বৃদ্ধি করা হয়: যখন একটি বার্তা সফলভাবে এর মাধ্যমে অনুরোধ করা হয় XCLAIM অথবা যখন একটি কল ব্যবহার করা হয় XREADGROUP.

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

থ্রেড স্টেট

টীম XINFO একটি থ্রেড এবং তার গ্রুপ সম্পর্কে বিভিন্ন তথ্য অনুরোধ করতে ব্যবহৃত হয়। উদাহরণস্বরূপ, একটি মৌলিক কমান্ড এই মত দেখায়:

> XINFO STREAM mystream
 1) length
 2) (integer) 13
 3) radix-tree-keys
 4) (integer) 1
 5) radix-tree-nodes
 6) (integer) 2
 7) groups
 8) (integer) 2
 9) first-entry
10) 1) 1524494395530-0
    2) 1) "a"
       2) "1"
       3) "b"
       4) "2"
11) last-entry
12) 1) 1526569544280-0
    2) 1) "message"
       2) "banana"

উপরের কমান্ডটি নির্দিষ্ট স্ট্রীম সম্পর্কে সাধারণ তথ্য প্রদর্শন করে। এখন একটু জটিল উদাহরণ:

> XINFO GROUPS mystream
1) 1) name
   2) "mygroup"
   3) consumers
   4) (integer) 2
   5) pending
   6) (integer) 2
2) 1) name
   2) "some-other-group"
   3) consumers
   4) (integer) 1
   5) pending
   6) (integer) 0

উপরের কমান্ডটি নির্দিষ্ট থ্রেডের সমস্ত গ্রুপের জন্য সাধারণ তথ্য প্রদর্শন করে

> XINFO CONSUMERS mystream mygroup
1) 1) name
   2) "Alice"
   3) pending
   4) (integer) 1
   5) idle
   6) (integer) 9104628
2) 1) name
   2) "Bob"
   3) pending
   4) (integer) 1
   5) idle
   6) (integer) 83841983

উপরের কমান্ডটি নির্দিষ্ট স্ট্রীম এবং গ্রুপের সমস্ত গ্রাহকদের জন্য তথ্য প্রদর্শন করে।
আপনি কমান্ড সিনট্যাক্স ভুলে গেলে, সাহায্যের জন্য শুধুমাত্র কমান্ডটিই জিজ্ঞাসা করুন:

> XINFO HELP
1) XINFO {subcommand} arg arg ... arg. Subcommands are:
2) CONSUMERS {key} {groupname}  -- Show consumer groups of group {groupname}.
3) GROUPS {key}                 -- Show the stream consumer groups.
4) STREAM {key}                 -- Show information about the stream.
5) HELP                         -- Print this help.

স্ট্রিম সাইজ সীমা

অনেক অ্যাপ্লিকেশন চিরতরে একটি স্ট্রীমে ডেটা সংগ্রহ করতে চায় না। প্রতি থ্রেডে সর্বাধিক সংখ্যক বার্তা অনুমোদিত হওয়া প্রায়শই দরকারী। অন্যান্য ক্ষেত্রে, নির্দিষ্ট থ্রেড আকারে পৌঁছে গেলে একটি থ্রেড থেকে অন্য স্থায়ী স্টোরে সমস্ত বার্তা স্থানান্তর করা কার্যকর। আপনি কমান্ডে MAXLEN প্যারামিটার ব্যবহার করে একটি স্ট্রিমের আকার সীমিত করতে পারেন XADD:

> XADD mystream MAXLEN 2 * value 1
1526654998691-0
> XADD mystream MAXLEN 2 * value 2
1526654999635-0
> XADD mystream MAXLEN 2 * value 3
1526655000369-0
> XLEN mystream
(integer) 2
> XRANGE mystream - +
1) 1) 1526654999635-0
   2) 1) "value"
      2) "2"
2) 1) 1526655000369-0
   2) 1) "value"
      2) "3"

MAXLEN ব্যবহার করার সময়, পুরানো রেকর্ডগুলি একটি নির্দিষ্ট দৈর্ঘ্যে পৌঁছালে স্বয়ংক্রিয়ভাবে মুছে ফেলা হয়, তাই স্ট্রিমটির একটি ধ্রুবক আকার থাকে। যাইহোক, এই ক্ষেত্রে ছাঁটাই রেডিস মেমরিতে সবচেয়ে কার্যকর উপায়ে ঘটে না। আপনি নিম্নলিখিত হিসাবে পরিস্থিতি উন্নত করতে পারেন:

XADD mystream MAXLEN ~ 1000 * ... entry fields here ...
উপরের উদাহরণে ~ আর্গুমেন্টের মানে হল যে আমাদের স্ট্রিমের দৈর্ঘ্যকে একটি নির্দিষ্ট মানের মধ্যে সীমাবদ্ধ করার প্রয়োজন নেই। আমাদের উদাহরণে, এটি 1000 (উদাহরণস্বরূপ, 1000, 1010, বা 1030) এর চেয়ে বড় বা সমান যেকোনো সংখ্যা হতে পারে। আমরা শুধু স্পষ্টভাবে উল্লেখ করেছি যে আমরা চাই আমাদের স্ট্রিম অন্তত 1000টি রেকর্ড সঞ্চয় করুক। এটি রেডিসের ভিতরে মেমরি ব্যবস্থাপনাকে অনেক বেশি দক্ষ করে তোলে।

আলাদা দলও আছে XTRIM, যা একই জিনিস করে:

> XTRIM mystream MAXLEN 10

> XTRIM mystream MAXLEN ~ 10

ক্রমাগত স্টোরেজ এবং প্রতিলিপি

রেডিস স্ট্রিম অ্যাসিঙ্ক্রোনাসভাবে স্লেভ নোডগুলিতে প্রতিলিপি করা হয় এবং AOF (সমস্ত ডেটার স্ন্যাপশট) এবং RDB (সকল লেখার ক্রিয়াকলাপের লগ) এর মতো ফাইলগুলিতে সংরক্ষণ করা হয়। কনজিউমার গ্রুপ স্টেটের প্রতিলিপিও সমর্থিত। অতএব, যদি একটি বার্তা মাস্টার নোডে "মুলতুবি" অবস্থায় থাকে, তাহলে স্লেভ নোডগুলিতে এই বার্তাটির একই অবস্থা থাকবে।

একটি স্ট্রীম থেকে পৃথক উপাদান অপসারণ

বার্তা মুছে ফেলার জন্য একটি বিশেষ কমান্ড আছে XDEL. কমান্ডটি মুছে ফেলার জন্য বার্তা আইডি অনুসরণ করে থ্রেডের নাম পায়:

> XRANGE mystream - + COUNT 2
1) 1) 1526654999635-0
   2) 1) "value"
      2) "2"
2) 1) 1526655000369-0
   2) 1) "value"
      2) "3"
> XDEL mystream 1526654999635-0
(integer) 1
> XRANGE mystream - + COUNT 2
1) 1) 1526655000369-0
   2) 1) "value"
      2) "3"

এই কমান্ডটি ব্যবহার করার সময়, আপনাকে অবশ্যই বিবেচনা করতে হবে যে প্রকৃত মেমরি অবিলম্বে প্রকাশ করা হবে না।

শূন্য দৈর্ঘ্যের প্রবাহ

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

উপসংহার

মেসেজ ব্রোকার, মেসেজ কিউ, ইউনিফাইড লগিং এবং হিস্ট্রি-কিপিং চ্যাট সিস্টেম তৈরি করার জন্য রেডিস স্ট্রিম আদর্শ।

যেমনটা আমি একবার বলেছিলাম নিকলাউস ওয়ার্থ, প্রোগ্রামগুলি হল অ্যালগরিদম প্লাস ডেটা স্ট্রাকচার, এবং Redis ইতিমধ্যেই আপনাকে উভয়ই দেয়৷

উত্স: www.habr.com

রেডিস স্ট্রিম - আপনার মেসেজিং সিস্টেমের নির্ভরযোগ্যতা এবং মাপযোগ্যতা