Google Cloud Pub/Sub একটি বিশ্বব্যাপী বিতরণ করা বার্তা বাস যা আপনার প্রয়োজন অনুযায়ী স্বয়ংক্রিয়ভাবে স্কেল করে। আপনি functions.pubsub
ব্যবহার করে Pub/Sub ইভেন্টগুলি পরিচালনা করে এমন একটি ফাংশন তৈরি করতে পারেন।
একটি পাব/সাব ফাংশন ট্রিগার করুন
যখনই একটি নির্দিষ্ট বিষয়ে একটি নতুন Pub/Sub বার্তা পাঠানো হয় আপনি একটি ফাংশন ট্রিগার করতে পারেন৷ আপনি অবশ্যই আপনার ফাংশনটি ট্রিগার করতে চান এমন Pub/Sub বিষয়ের নাম উল্লেখ করতে হবে এবং onPublish()
ইভেন্ট হ্যান্ডলারের মধ্যে ইভেন্ট সেট করুন:
exports.helloPubSub = functions.pubsub.topic('topic-name').onPublish((message) => { // ... });
পাব/সাব মেসেজ পেলোড অ্যাক্সেস করুন {:#access-pub/sub}
Pub/Sub বার্তার জন্য পেলোড আপনার ফাংশনে ফিরে আসা Message
বস্তু থেকে অ্যাক্সেসযোগ্য। Pub/Sub মেসেজ বডিতে JSON-এর সাথে মেসেজের জন্য, Cloud Functions জন্য Firebase SDK-এ মেসেজ ডিকোড করার জন্য একটি সহায়ক প্রপার্টি রয়েছে। উদাহরণস্বরূপ, এখানে একটি সাধারণ JSON পেলোড সহ প্রকাশিত একটি বার্তা রয়েছে:
gcloud pubsub topics publish topic-name --message '{"name":"Xenia"}'
আপনি json
সম্পত্তির মাধ্যমে এই মত একটি JSON ডেটা পেলোড অ্যাক্সেস করতে পারেন:
// Get the `name` attribute of the PubSub message JSON body. let name = null; try { name = message.json.name; } catch (e) { functions.logger.error('PubSub message was not JSON', e); }
অন্যান্য, নন-JSON পেলোডগুলি বার্তা অবজেক্টে বেস64 এনকোড করা স্ট্রিং হিসাবে Pub/Sub বার্তায় থাকে। নিম্নলিখিত মত একটি বার্তা পড়তে, আপনি দেখানো হিসাবে base64 এনকোডেড স্ট্রিং ডিকোড করতে হবে:
gcloud pubsub topics publish topic-name --message 'MyMessage'
// Decode the PubSub Message body. const messageBody = message.data ? Buffer.from(message.data, 'base64').toString() : null;
অ্যাক্সেস বার্তা বৈশিষ্ট্য {:#access-message}
Pub/Sub মেসেজ পাবলিশ কমান্ডে সেট করা ডেটা অ্যাট্রিবিউট সহ পাঠানো যেতে পারে। উদাহরণস্বরূপ, আপনি একটি name
বৈশিষ্ট্য সহ একটি বার্তা প্রকাশ করতে পারেন:
gcloud pubsub topics publish topic-name --attribute name=Xenia
আপনি Message.attributes
থেকে এই ধরনের গুণাবলী পড়তে পারেন:
// Get the `name` attribute of the message. const name = message.attributes.name;
আপনি লক্ষ্য করতে পারেন যে কিছু মৌলিক ডেটা যেমন বার্তা আইডি বা বার্তা প্রকাশের সময় Message.attributes
এ উপলব্ধ নেই। এটিকে ঘিরে কাজ করার জন্য, আপনি ট্রিগারিং ইভেন্টের EventContext
এ এই বিবরণগুলি অ্যাক্সেস করতে পারেন। যেমন:
exports.myFunction = functions.pubsub.topic('topic1').onPublish((message, context) => {
console.log('The function was triggered at ', context.timestamp);
console.log('The unique ID for the event is', context.eventId);
});