পাব/সাব ট্রিগার


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);
});