問題タブ [google-cloud-pubsub]

私がやろうとしていること

Gmail API + Google Pub/Sub API を使用して、 ed インボックスでメールを受信するたびに、EC2 インスタンスで実行されているノード サーバーにプッシュ通知を配信しています。watch()サーバーのドメインをconsole.developers.google.comの Push セクションに追加し、Pub/Sub API 用にサブスクリプションを作成して Push エンドポイント URL を追加します。エンドポイントは次のようになりますhttps://example.com/receive。

私がやりたいのは、これをローカルでテストすることです。

問題

Google からローカル ホスト サーバーにプッシュ通知を送信するにはどうすればよいですか? テストするとき、新着メールの通知が に送信されるようにしhttp://localhost:8080/receiveます。おそらくngrokを使用して localhost を公開することを考えていましたが、問題は、ngrok の URL が変更されるたびに (ドメインを所有している) Google の証拠を手動でアップロードする必要があることです。これは大きな頭痛の種です。

localhost サーバーで新しい電子メール通知を受信するためのより良い方法はありますか?

Google Cloud Dataflow を使用して、トピックからの PubSub メッセージ データを BigQuery テーブルに挿入したいと考えています。すべてうまく機能しますが、BigQuery テーブルに「 ff」のような判読できない文字列が表示されます。これは私のパイプラインです:

私の単純な StringToRowConverter 関数は次のとおりです。

そして、これは私が POST リクエストで送信したメッセージです:

私は何が欠けていますか？ありがとうございました！

Cloud Pub/Sub サービスのプッシュ サブスクライバーとして構成したいコンピューティング エンジン インスタンスで構成される Google Cloud プロジェクトがあります。インスタンスに自己署名証明書を使用して Apache Web サーバーをセットアップし、静的 IP アドレスを持つインスタンスを指す DNS エントリ (abc.mydomain.com) も作成しました。私はすでにウェブマスターのドメイン (mydomain.com) の確認済みの所有者です。

Cloud コンソールからサブスクリプションを追加するたびに、「サブスクリプションを追加できませんでした」というエラーで失敗し、その他の有用な情報は表示されません。

助けてください。

同じプロジェクトの Pub/Sub プル サブスクリプションに接続する必要がある Dataproc クラスタで Spark（scala）ジョブを実行しようとしていますが、次のエラー メッセージが表示されます。私の Dataproc クラスタ内のマシンには「https://www.googleapis.com/auth/pubsub」スコープがないと思います。

Dataproc クラスタのマシンに認証スコープを追加できますか?

PS: 必要に応じてクラスターを再作成しても問題ありません。

私は現在、Google Cloud PubSub のgo ライブラリを試しながら、同時にドキュメントを調べています。

私のコードは、ドキュメントPullWaitによると次のことを行う関数の動作をテストします。

PullWait は、サブスクリプションからメッセージをプルします。サブスクリプション キューに十分なメッセージが残っていない場合、少なくとも n 個のメッセージが到着するか、タイムアウトが発生するまでブロックされます。n は 100 を超えることはできません。

ただし、私のテストでは、n指定された値に関係なく、常にすぐmに m <= n のメッセージを受信することが示されています。ここで何か不足していますか？

使用されたコードの抜粋:

当時、キューにはメッセージが 1 つしか含まれていませんでしたが、すぐに返されました。

2015/11/04 11:45:15 メッセージ [msg-id=2384294654226]: 「こんにちは、私の友人」

プロジェクトProject 1でトピックを作成しました。このトピックに毎分メッセージを投稿する Google アプリ エンジンのアプリがあります。

このトピックにサブスクライブしてメッセージを受信する2 番目のプロジェクト ( Project 2 )に Google クラウド コンピューティング マシンがあります。

Project 2のマシンにアクセス権を与えていませんでしたが、アクセス権がなくてもメッセージを受信できました。より正確には、作成したトピックに関連する特定のアクセス許可を書きませんでした。

私の質問は次のとおりです。

1-これは正常ですか？プロジェクト 2のマシンで「アクセス禁止エラー」が発生することはありませんか?

2- 特定のトピックへのアクセスを制限するにはどうすればよいですか?

これが私の購読部分のコードです：

この質問は、 Google Cloud Pub/Sub プッシュ サブスクライバーを構成できないのフォロー アップです

回答によると、プッシュ サブスクライバーを使用する場合、自己署名証明書はサポートされません。letsencrypt クライアント経由で生成された証明書はサポートされていますか? letsencrypt を使用することをお勧めしますか?

メールで受信したすべての新しい受信トレイ メッセージに関するプッシュ通知を取得しようとしています。pubsub doc に記載されているように、pubsub クライアントを構成しました。コードは次のとおりです。

上記のプログラムを実行すると、次のエラーが発生します。

トレースバック (最新の呼び出しが最後): ファイル "/home/kmittal/workspace/engine/workers/newPubSubClient.py"、82 行目、service.users().watch(userId='me', body=request).execute 内() ファイル "/usr/local/lib/python2.7/dist-packages/oauth2client/util.py" の 135 行目、positional_wrapper で return wrap(*args, **kwargs) ファイル "/usr/local/lib/ python2.7/dist-packages/googleapiclient/http.py", 行 723, in execute raise HttpError(resp, content, uri=self.uri) googleapiclient.errors.HttpError: https://www.googleapis.com/gmail /v1/users/me/watch?alt=json が「無効な topicName が projects/SOME_ANOTHER_PROJECT/topics/* と一致しません」を返しました">