Pub/Sub メッセージの作成と応答

Python |Java |Node.js |Go |Ruby |PHP |.NET

Google Cloud Pub/Sub は、アプリケーション間で信頼できる多対多の非同期メッセージングを行います。パブリッシャー アプリケーションはメッセージを「トピック」に送信し、その他のアプリケーションはそのトピックにサブスクライブしてメッセージを受信できます。

要件

• App Engine の Ruby 用「Hello, World!」の手順に沿って環境とプロジェクトを設定し、App Engine の Ruby アプリの構造について理解します。
• このドキュメントで説明しているサンプル アプリケーションを実行するために必要なので、プロジェクト ID をメモして保存します。

  サンプルアプリのクローンの作成

  サンプルアプリをローカルマシンにコピーし、pubsub ディレクトリに移動します。

  git clone https://github.com/GoogleCloudPlatform/ruby-docs-samples
  cd ruby-docs-samples/appengine/pubsub
  

  トピックとサブスクリプションを作成する

  トピックとサブスクリプションを作成します。Pub/Sub サーバーがリクエストを送信するエンドポイントも指定します。

  gcloud beta pubsub topics create YOUR_TOPIC_NAME
  gcloud beta pubsub subscriptions create YOUR_SUBSCRIPTION_NAME \
      --topic YOUR_TOPIC_NAME \
      --push-endpoint \
      https://YOUR_PROJECT_ID.appspot.com/pubsub/push?token=YOUR_TOKEN \
      --ack-deadline 10
  

  YOUR_TOKEN は、ランダムなシークレット トークンで置き換えます。push エンドポイントがこれを使用してリクエストを検証します。

  app.yaml を編集する

  app.yaml を編集して、プロジェクト ID、トピック、検証トークンの環境変数を設定します。

  appengine/pubsub/app.yaml

  GitHub で表示

  env_variables:
      PUBSUB_TOPIC: <your-topic-name>
      # This token is used to verify that requests originate from your
      # application. It can be any sufficiently random string.
      PUBSUB_VERIFICATION_TOKEN: <your-token>

  コードのレビュー

  サンプルアプリでは、Google Cloud Client ライブラリを使用しています。

  このサンプルアプリでは、app.yaml ファイルに設定された値を使用して環境変数を設定します。push リクエスト ハンドラは、これらの値を使用して、Pub/Sub からのリクエストで、信頼できる送信元から送信されていることを確認します。

  appengine/pubsub/app.rb

  GitHub で表示

  topic  = pubsub.topic ENV["PUBSUB_TOPIC"]
  PUBSUB_VERIFICATION_TOKEN = ENV["PUBSUB_VERIFICATION_TOKEN"]

  このサンプルアプリは、グローバル リストを使用して、このインスタンスで受信したメッセージを保存します。

  appengine/pubsub/app.rb

  GitHub で表示

  # List of all messages received by this instance
  messages = []

  このメソッドは、push されたメッセージを受信し、messages グローバル リストに追加します。

  appengine/pubsub/app.rb

  GitHub で表示

  post "/pubsub/push" do
    halt 400 if params[:token] != PUBSUB_VERIFICATION_TOKEN
  
    message = JSON.parse request.body.read
    payload = Base64.decode64 message["message"]["data"]
  
    messages.push payload
  end

  このメソッドは、App Engine ウェブアプリと連携して新しいメッセージを公開し、受信したメッセージを表示します。

  appengine/pubsub/app.rb

  GitHub で表示

  get "/" do
    @messages = messages
  
    slim :index
  end
  
  post "/publish" do
    topic.publish params[:payload]
  
    redirect "/", 303
  end

  サンプルをローカルで実行する

  ローカルで実行する場合、Google Cloud SDK で Google Cloud API を使用するための認証を行うことができます。要件に記載されているとおりに環境をセットアップしていれば、この認証のための gcloud init コマンドはすでに実行されています。

  依存関係をインストールします。

  bundle install
  

  次に、アプリケーションを起動する前に環境変数を設定します。

  export GOOGLE_CLOUD_PROJECT=[your-project-id]
  export PUBSUB_VERIFICATION_TOKEN=[your-verification-token]
  export PUBSUB_TOPIC=[your-topic]
  bundle exec ruby app.rb -p 8080
  

  プッシュ通知をシミュレートする

  アプリケーションは、ローカルでメッセージを送信できますが、push メッセージを受信することはできません。push メッセージをシミュレートするには、ローカル プッシュ通知エンドポイントに HTTP リクエストを送信します。このサンプルには、sample_message.json というファイルが含まれています。

  curl または httpie を使用して、HTTP POST リクエストを送信できます。

  curl -i --data @sample_message.json ":8080/pubsub/push?token=[your-token]"
  

  または

  http POST ":8080/pubsub/push?token=[your-token]" < sample_message.json
  

  レスポンス:

  HTTP/1.1 200 OK
  Content-Type: text/html;charset=utf-8
  Content-Length: 13
  X-Xss-Protection: 1; mode=block
  X-Content-Type-Options: nosniff
  X-Frame-Options: SAMEORIGIN
  Server: WEBrick/1.3.1 (Ruby/2.3.0/2015-12-25)
  Date: Wed, 20 Apr 2016 20:56:23 GMT
  Connection: Keep-Alive
  
  Hello, World!
  

  リクエストの完了後、localhost:8080 を更新すると、受信メッセージのリストにメッセージが表示されます。

  App Engine で実行する

  gcloud コマンドライン ツールを使用してデモアプリを App Engine にデプロイするには、app.yaml が存在するディレクトリから次のコマンドを実行します。

  gcloud app deploy
  

  これで、https://[YOUR_PROJECT_ID].appspot.com のアプリケーションにアクセスできます。フォームを使用してメッセージを送信できますが、通知を受信するアプリケーションのインスタンスが常に同じとは限りません。複数のメッセージを送信してページを更新すると、受信メッセージを確認できます。