問題タブ [google-cloud-pubsub]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Java から Google Cloud PubSub エミュレータを使用する
Pubsub.Builderローカルの PubSub エミュレーターを指すルート URLを設定しました (localhost:8036私の場合)。エミュレーターがテスト プッシュを受信しているように見えますが、エラー 400 Bad Request が表示されます。
コードを公開:
エミュレーターのコンソール出力には、次のように表示されます (これは非常に基本的なものですPublishRequest)。
デフォルトの PubSub クライアントは別のプロトコルを使用しているようですが、それを構成する方法がわかりません。
com.google.apis:google-api-services-pubsubローカルエミュレータでライブラリを使用するにはどうすればよいですか?
google-cloud-pubsub - Google Cloud Pub/Sub API 割り当てはどこでも定義されていますか
コンソールには、ディスカバリ、管理、パブリッシュ、およびサブスクライブのクォータがありますが、これら 4 つのカテゴリの定義はどこにも見つかりません。
サブスクリプションをリストする場合、それはディスカバリーですか? サブスクリプションを取得した場合、それはディスカバリーですか? トピックまたはサブスクリプションを作成または削除すると、それは管理者になりますか?
ありがとう
ポール
編集: ここで Pub/Sub dquota ドキュメントを見ることができますが、この質問には答えていません。 https://cloud.google.com/pubsub/quotas
google-cloud-dataflow - Dataflow ワーカー ログを Cloud Pubsub にエクスポートするにはどうすればよいですか?
Cloud Dataflow のワーカー ログに対して二次処理を実行したいと考えています。それを行う簡単な方法はありますか？
google-cloud-dataflow - DataFlow と Cloud Pub Sub で冪等性を確保するにはどうすればよいですか?
Cloud DataFlow と PubSub を使用するときに冪等性を確保する最善の方法に興味がありますか?
現在、MySQL データベースでレコードを処理および保存するシステムがあります。レポートの一部に DataFlow を使用することに興味がありますが、同じメッセージを誤って二重にカウントしないようにするために何をする必要があるかを理解したいと思っていました。
私の混乱は 2 つの部分で発生します。1 つは、メッセージを 1 回だけ送信するようにすること、もう 1 つはメッセージを 1 回だけ処理するようにすることです。
私の腸は次のようになります。
関心のあるイベントが MySQL データベースに記録されるたびに、それを PubSub メッセージに変換して PubSub に公開します。成功したと仮定して、MySQL レコードと一緒に返された PubSub id を記録します。そうすれば、PubSub ID があれば、送信したことがわかり、再度送信する必要はありません。PubSub への公開が失敗した場合は、もう一度送信する必要があることがわかります。すべて良い。
しかし、PubSub の書き込みが成功した後に MySQL への書き込みが失敗した場合、同じメッセージを pub sub に再度パブリッシュすることになる可能性があるため、DataFlow 側で、このケースと PubSub がメッセージを 2 回送信するケースの両方を処理する必要があります ( https://cloud.google.com/pubsub/subscriber#guaranteesごと）。
これを処理する最良の方法は何ですか? AppEngine またはその他のシステムでは、データストアをチェックして、作成中の新しいレコードが存在するかどうかを確認しますが、DataFlow でそれを行う方法がわかりません。メッセージが 2 回処理されるのを防ぐフィルターを簡単に実装する方法はありますか? それとも、DataFlow はすでにこれを処理していますか?
ruby-on-rails - Ruby on Rails で pubsub サービス オブジェクトを使用して watch() を呼び出す方法
google-api-client gem を使用して、Google サービスを Rails アプリケーションに統合しています。PubSub の範囲で、a/c でトピックとサブスクリプションを作成できますが、watch() メソッドの呼び出し中に問題に直面しています。以下のようなサービスオブジェクトを介してwatchメソッドを呼び出すフローを誰かに教えてもらえますか
以下は、サービスオブジェクトを取得するための私のスクリプトです
google-cloud-platform - Google PubSub - トピック内のメッセージのカウント
Google の PubSub のドキュメントを調べ、Google Cloud Monitoring も調べてみましたが、トピックのキュー サイズを把握する手段が見つかりませんでした。
分析に PubSub を使用する予定なので、キュー数を監視することが重要です。これにより、サブスクライバー数をスケールアップ/スケールダウンできます。
私は何が欠けていますか？
ruby-on-rails - Gmail ウォッチ メソッドの呼び出しエラー
メールボックスの更新を取得するために gmail の watch メソッドを呼び出していますが、エラーが発生しています
これがコードです
誰でもこれで何が間違っているのか教えてもらえますか?