रीयल-टाइम आपातकालीन प्रतिक्रिया प्रणाली:अपस्टैश, रेडिस और क्यूस्टैश का लाभ उठाना

परिचय

सर्वर रहित क्यों?

1. बजट :यदि कोई देश किसी उभरती आपदा से नहीं गुज़र रहा है, तो क्या निर्णय लेने वाली भूमिका में कोई भी व्यक्ति अप्रयुक्त गणना शक्ति के लिए भुगतान को मंजूरी देने में सक्षम होगा? मुझे ऐसा संदेह है.
2. यातायात में बढ़ोतरी :कल्पना कीजिए कि एक अलार्म बजता है और लाखों लोग निकटतम आश्रय खोजने के लिए वेब प्लेटफ़ॉर्म तक पहुंचते हैं। आपकी REST API इस अचानक आरपीएस (अनुरोध-प्रति-सेकंड) वृद्धि को कैसे संभालेगी? आवश्यक रीयलटाइम घटकों के बारे में क्या?

रेडिस क्यों?

QStash क्यों?

आवश्यकताएँ

• एक अपस्टैश खाता, जिससे आप एक Redis डेटाबेस बनाएंगे और QStash एंडपॉइंट या विषय का उपयोग करेंगे;
• एक एबली खाता और एक वेबहुक एकीकरण सेट अप
• एक Next.js प्रोजेक्ट;
• यदि आप इंटरनेट पर उपलब्ध URL पर स्थानीय अनुरोधों को प्रॉक्सी करना चाहते हैं तो ngrok जैसी एक टनलिंग सेवा;
• कोई भी पैकेज प्रबंधक जो अनुरोधित पुस्तकालयों का समर्थन करता है। यह आलेख npm का उपयोग करेगा, लेकिन यह अनिवार्य नहीं है।

सेटअप

सर्वर रहित फ़ंक्शन

1. प्रति-मार्ग दृष्टिकोण. निम्नलिखित निर्यात को वांछित मार्ग पर जोड़ें:

   export const config = {
    runtime: "experimental-edge",
   };

2. वैश्विक दृष्टिकोण. बढ़त बनाना डिफ़ॉल्ट रनटाइम, अपनी अगली.config,js फ़ाइल में निम्नलिखित जोड़ें:

   const nextConfig = {
    // ...
    experimental: {
    runtime: "experimental-edge",
    },
    // ...
   };

अपस्टैश

कुशल

वैकल्पिक:स्थानीय सुरंग बनाना

वास्तुकला

प्रवाह

1. नागरिक , जो किसी आश्रय या स्थान की जानकारी तक पहुंच सकता है, और बंकर में जाने के अपने इरादे की घोषणा कर सकता है
2. व्यवस्थापक , जो बंकर के लॉजिस्टिक्स डेटा को संशोधित कर सकता है और उपलब्धता को संशोधित कर सकता है (उदाहरण के लिए, पुष्टि करें कि कोई व्यक्ति/परिवार स्थान पर पहुंच गया है)

डेटा

• <पी> एक आश्रय की जानकारी, जो रेडिस हैश का रूप ले सकती है और इसमें निम्नलिखित गुण हैं:
  • कुंजी का नाम country-city-number (उदा:RO-CJ-01 )
  • उपलब्धता (उदा:300 )
  • विशेषताएं (उदा:["disabled persons special acces", "counseling"] )
  • संसाधन:

    {
     resource: quantity,
     or
     resource: list
     ...
    }

    उदाहरण:

    {
     "water": "200 liters",
     "medicine": ["insuline", ...]
    }

  • बिजली:yes/no
  • हीटिंग:yes/no
  • स्थिति:[longitude, latitude] या

    {
     longitude: number,
     latitude: number
    }

  • _id:हम इसे यादृच्छिक रूप से उत्पन्न करेंगे
• <पी> किसी स्थान की जानकारी
  <पी> जबकि हम कर सकते हैं निर्दिष्ट स्थान के लिए उपलब्ध आश्रयों को खोजने के लिए एक नेस्टेड क्वेरी करें, क्वेरी को सरल और अनुकूलित करने के लिए उन्हें एक अलग डेटा संरचना के रूप में संग्रहीत करना एक बेहतर विचार हो सकता है। ऐसा करने के लिए, हम रेडिस सेट का उपयोग कर सकते हैं और तत्वों को <geographical-unit>-<name> नाम दे सकते हैं (उदा:country-RO या city-CJ ). इस तरह हम नकल को भी रोक रहे हैं
  <पी> उदा:

   city-CJ : ["RO-CJ-01", "RO-CJ-02", "RO-CJ-03"]

1. <पी> लगातार अपडेट करें आश्रय की उपलब्धता कुंजी:एक उपयोगकर्ता आने के अपने इरादे की घोषणा करता है (अकेले या परिवार के साथ/आदि) => हम x से वृद्धि करते हैं; व्यवस्थापक को पता चलता है कि पुष्टि मान्य नहीं है => हम x से कमी करते हैं (या -x द्वारा वृद्धि)
   <पी> यहां समस्या यह है कि व्यवस्थापक को सत्य के स्रोत के रूप में कार्य करना चाहिए और नागरिक के स्थान पर नज़र रखनी चाहिए; इसके अलावा, आश्रय के डेटा पर तुरंत भरोसा नहीं किया जा सकता

2. <पी> एक अलग स्ट्रिंग कुंजी बनाएं shelter-"availability" नाम दिया गया है (उदा:RO-CJ-01-availability ) और रियलटाइम-अपडेटेड वैल्यू को स्टोर करें। इस तरह हम रियलटाइम अपडेट कर सकते हैं, और अपनी हैश की उपलब्धता कुंजी को सत्य के स्रोत के रूप में रख सकते हैं।
   <पी> ध्यान दें कि क्लाइंट पक्ष पर हम हैश और स्ट्रिंग कुंजी दोनों लाएंगे, और उन्हें वास्तविक उपलब्धता और अनुमानित उपलब्धता के रूप में प्रस्तुत करेंगे। एक वैकल्पिक दृष्टिकोण यह होगा कि केवल स्ट्रिंग को लाया जाए और आवश्यकता पड़ने पर सत्य के स्रोत पर वापस लौटाया जाए। हालाँकि इससे नेटवर्क लोड कम हो जाएगा, व्यवस्थापक को डेटा को लगातार सत्यापित करने की आवश्यकता होगी (जैसा कि पहले परिदृश्य में) और, वास्तव में कम प्राप्त करें, हमें आश्रय की उपलब्धता कुंजी को अलग से संग्रहीत करने की आवश्यकता होगी (याद रखें, हमें अभी भी अन्य जानकारी प्राप्त करने की आवश्यकता है!)।

सॉर्टिंग

उदाहरण

अंतिमबिंदु

• एक डेटा एंडपॉइंट जो क्लाइंट को किसी भी अनुरोधित जानकारी प्रदान करेगा
• हमारे डेटा प्रकारों को बनाने या अपडेट करने के लिए एक एडपॉइंट

ग्राहक

import { useEffect, useState } from "react";
 
import "../styles/globals.css";
 
import { configureAbly } from "@ably-labs/react-hooks";
 
export default function App({ Component, pageProps }) {
 const [loaded, setLoaded] = useState(false);
 useEffect(() => {
 configureAbly({
 // In a production system, you should use authentication
 key: process.env.NEXT_PUBLIC_ABLY_API_KEY,
 });
 setLoaded(true);
 }, []);
 
 if (!loaded) return <div>loading...</div>;
 return <Component {...pageProps} />;
}

import { useChannel } from "@ably-labs/react-hooks";
 
export default function Test() {
 const [availability] = useChannel("availability", (msg) => {
 console.log(msg);
 });
 
 return <></>;
}

डेटाबेस के साथ कार्य करना

नया डेटा जोड़ना

export default async (req) => {
 let data = await req.json();
 
 if (data.type === "shelter") {
 // Remove the 'type' key as it is not neccesary anymore
 delete data.type;
 const { name: shelter, availability } = data;
 
 let shelterData = data;
 // Generate a random id.
 shelterData._id = Math.random()
 .toString(36)
 .replace(/[^a-z]+/g, "")
 .substring(0, 7);
 
 // Store the shelter's info as a hash
 await redis.hset(shelter, shelterData);
 
 // Store the realtime-updated availability as a string
 await redis.set(shelter + "-availability", availability);
 return new Response("ok");
 } else if (data.type === "location") {
 const { name: location, shelters } = data;
 
 await redis.sadd(location, ...shelters);
 
 return new Response("ok");
 }
};

मौजूदा डेटा अपडेट कर रहा है

availability.publish("update", {
 shelter: "RO-CJ-01",
 availability: 1, // Or -x, if the user cancels.
});

await redis.incrby(shelter + "-availability", value);

डेटा पुनर्प्राप्त करना

संक्षेप में कहें तो