QStash का उपयोग करके रेडिस स्टेट को अपने डेटाबेस के साथ सहजता से सिंक्रोनाइज़ करें

QStash क्या है?

QStash के साथ CRON जॉब एंडपॉइंट बनाना

// Key stored in Redis. A key is created for each user, and made unique by their ID.
const quotaKey = `user:${userId}:quota`;
 
// Call the INCR command to increment the value of the key by 1.
const quota = await redis.incr(quotaKey);
 
// If the value of the key is 1, it means the key has been created.
// We can set an expiration date of 24 hours to this key by using the EXPIRE command.
if (quota === 1) {
 await redis.expire(quotaKey, 60 * 60 * 24);
}

touch pages/api/cron/update-usage.ts

npm install @upstash/qstash

• SCAN का उपयोग करके Redis से सभी उपयोगकर्ताओं की कोटा कुंजियाँ प्राप्त करें (प्रदर्शनकारी कर्सर-आधारित पेजिनेशन) .
• SCAN से मिली प्रत्येक कुंजी के लिए , एक users बनाएं उपयोगकर्ता की आईडी और उनके कोटा वाली वस्तुओं की सारणी।
• users के अंदर प्रत्येक उपयोगकर्ता के लिए एक लेनदेन बनाएं डेटाबेस में अपना कोटा अद्यतन करने के लिए सरणी। यह प्रिज्मा का उपयोग करके किया जाता है।
• एंडपॉइंट फ़ंक्शन को verifySignature के साथ निर्यात करें @upstash/qstash/nextjs से कार्य करें यह सुनिश्चित करने के लिए कि केवल QStash ही समापन बिंदु को ट्रिगर कर सकता है।

// /pages/api/cron/update-usage.ts
import type { NextApiRequest, NextApiResponse } from "next";
 
import { verifySignature } from "@upstash/qstash/nextjs";
 
import prisma from "@/lib/prisma";
 
// Generate an Upstash Redis instance using environment variables.
// Make sure those are defined in your .env file.
const redis = new Redis({
 url: process.env.UPSTASH_REDIS_REST_URL!,
 token: process.env.UPSTASH_REDIS_REST_TOKEN!,
});
 
// Required by `@upstash/qstash`.
export const config = { api: { bodyParser: false } };
 
// Update the usage of every user by pulling the data from the Redis database into the Prisma database.
async function handler(req: NextApiRequest, res: NextApiResponse) {
 // Contains all the keys found during the `SCAN`.
 const keys: string[] = [];
 // Current position of the cursor, updated after each `SCAN`.
 let cursor = 0;
 
 // Execute the cursor-based pagination using the `SCAN` command.
 // Redis return `0` when the cursor is at the end of the pagination.
 do {
 const [nextCursor, newKeys] = await redis.scan(cursor, {
 // Match the pattern of the keys we want to find, where `*` is a wildcard.
 match: "user:*:quota",
 // Limit the number of keys returned by the `SCAN` command.
 count: 10,
 });
 
 cursor = nextCursor;
 keys.push(...newKeys);
 } while (cursor !== 0);
 
 // Array of objects containing the user's ID and their quota.
 const users: { id: number; quota: number }[] = [];
 
 // Get the usage of each user from Redis based on the keys found.
 for (const key of keys) {
 // A key should be in the format `user:${id}:quota`. Split the key to get the ID.
 const id = key.split(":")[1];
 // Get the current quota of the user using the `GET` command.
 const quota = await redis.get(`user:${id}:quota`);
 
 users.push({ id: parseInt(id, 10), quota });
 }
 
 // Create a transaction for each user to update their quota in the database.
 const promises = users.map((user) =>
 prisma.user.update({
 where: { id: user.id },
 data: { quota: user.quota },
 }),
 );
 
 // Run all transactions.
 await Promise.all(promises);
 
 return res.status(200).json({ message: "OK" });
}
 
// Export the handler with the `verifySignature` function to make sure only
// QStash can authenticate to trigger the CRON job.
export default verifySignature(handler);

QStash की स्थापना

• QSTASH_CURRENT_SIGNING_KEY
• QSTASH_NEXT_SIGNING_KEY

निष्कर्ष