Firebase Summit で発表されたすべての情報をご覧ください。Firebase を使用してアプリ開発を加速し、自信を持ってアプリを実行する方法を紹介しています。詳細

Pub / Subトリガー

コレクションでコンテンツを整理 必要に応じて、コンテンツの保存と分類を行います。

Google Cloud のPub/Subは、必要に応じて自動的にスケーリングする、グローバルに分散されたメッセージ バスです。 functions.pubsub を使用して、Pub/Sub イベントを処理するfunctions.pubsubを作成できます。

pub/sub 関数をトリガーする

新しい Pub/Sub メッセージが特定のトピックに送信されるたびに、関数をトリガーできます。関数をトリガーする Pub/Sub トピック名を指定し、 onPublish()イベント ハンドラ内でイベントを設定する必要があります。

exports.helloPubSub = functions.pubsub.topic('topic-name').onPublish((message) => {
  // ...
});

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 ペイロードは、メッセージ オブジェクト内の base64 でエンコードされた文字列として 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;

メッセージ属性へのアクセス

Pub/Sub メッセージは、publish コマンドで設定されたデータ属性で送信できます。たとえば、 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では、メッセージ ID やメッセージ公開時間などの一部の基本データが利用できないことに気付くかもしれません。これを回避するには、トリガー イベントの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);
});