محرک های Pub/Sub


Google Cloud 's Pub/Sub یک گذرگاه پیام توزیع شده در سطح جهانی است که به طور خودکار در صورت نیاز شما مقیاس می شود. هر زمان که یک پیام Pub/Sub جدید به یک موضوع خاص ارسال می شود، می توانید یک تابع را فعال کنید.

برای شروع، ماژول های مورد نیاز برای مدیریت رویدادهای Pub/Sub را وارد کنید:

Node.js پایتون 
const {onMessagePublished} = require("firebase-functions/v2/pubsub");
const logger = require("firebase-functions/logger");
index.js


from firebase_functions import pubsub_fn
main.py

عملکرد را فعال کنید

شما باید نام موضوع Pub/Sub را که می‌خواهید عملکرد شما را فعال کند مشخص کنید و رویداد را در کنترل کننده رویداد تنظیم کنید:

Node.js پایتون 
exports.hellopubsub = onMessagePublished("topic-name", (event) => {
index.js


@pubsub_fn.on_message_published(topic="topic-name")
def hellopubsub(event: pubsub_fn.CloudEvent[pubsub_fn.MessagePublishedData]) -> None:
    """Log a message using data published to a Pub/Sub topic."""
main.py

به محموله پیغام میخانه/فرعی دسترسی پیدا کنید

محموله پیام Pub/Sub از شیء پیامی که به عملکرد شما بازگردانده شده است قابل دسترسی است. برای پیام‌های دارای JSON در متن پیام Pub/Sub ، Firebase SDK for Cloud Functions دارای ویژگی کمکی برای رمزگشایی پیام است. به عنوان مثال، در اینجا پیامی با یک بار ساده JSON منتشر شده است:

gcloud pubsub topics publish topic-name --message '{"name":"Xenia"}'

شما می توانید از طریق ویژگی json به یک محموله داده JSON مانند این دسترسی داشته باشید:

Node.js پایتون 
  // Get the `name` attribute of the PubSub message JSON body.
  let name = null;
  try {
    name = event.data.message.json.name;
  } catch (e) {
    logger.error("PubSub message was not JSON", e);
  }
index.js
# Get the `name` attribute of the PubSub message JSON body.
try:
    data = event.data.message.json
except ValueError:
    print("PubSub message was not JSON")
    return
if data is None:
    return
if "name" not in data:
    print("No 'name' key")
    return
name = data["name"]
main.py

سایر محموله‌های غیر JSON در پیام Pub/Sub به‌عنوان رشته‌های کدگذاری شده base64 در شیء پیام وجود دارند. برای خواندن پیامی مانند زیر، باید رشته رمزگذاری شده base64 را مطابق شکل رمزگشایی کنید:

gcloud pubsub topics publish topic-name --message 'MyMessage'
Node.js پایتون 
// Decode the PubSub Message body.
const message = event.data.message;
const messageBody = message.data ?
      Buffer.from(message.data, "base64").toString() :
      null;
index.js
# Decode the PubSub message body.
message_body = base64.b64decode(event.data.message.data)
main.py

دسترسی به ویژگی های پیام

پیام Pub/Sub را می توان با ویژگی های داده تنظیم شده در دستور انتشار ارسال کرد. به عنوان مثال، می توانید پیامی را با ویژگی name منتشر کنید: 

gcloud pubsub topics publish topic-name --attribute name=Xenia

شما می توانید چنین ویژگی هایی را از ویژگی متناظر شی پیام بخوانید:

Node.js پایتون 
// Get the `name` attribute of the message.
const name = event.data.message.attributes.name;
index.js
# Get the `name` attribute of the message.
if "name" not in event.data.message.attributes:
    print("No 'name' attribute")
    return
name = event.data.message.attributes["name"]
main.py