google-cloud-pubsub

    3

    1答えて

    Google Cloud Pub/Subを実装して、Javaを使用してメッセージを受信しようとしていますが、Java用のドキュメントが見つかりませんでした。 プルを介してメッセージを受け取ることができます。また、エンドポイントをローカルに設定してテストすることは、非常に役立ちます。 ドメインをエンドポイントとして確認して追加しました。そのエンドポイントでメッセージを受信するために次に何をすべきか疑

    0

    1答えて

    https://status.cloud.google.com/はすべてのGoogleクラウドサービスからステータスを取得します。とにかく私はjsonの形式でGoogleのpubsubのステータスを取得することができますか? また、このURLのhttps://console.cloud.google.com/home/dashboard?project=project_id URLが有効であること

    0

    1答えて

    APIからメトリックpubsubを取得する方法を知りたい。 (私はこの話題Google PubSub - Counting messages in topicを見ましたが、それは同じ問題ではありません)。 Logging APIからそれらを取得しようとすると、404エラーが返されます。 権利がないか、権利が不足していますか?お時間を Client error: `GET https://loggi

    0

    1答えて

    ドキュメントを1として https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector下に建てられたのjarターゲット/ CPS-カフカ-のconnector.jar のjava -jar cps-のようにコマンドライン上で実行中カフカ-のconnector.jar それは、CPS-カフカ-のconnector.j

    0

    1答えて

    私はpythonスクリプトからgoogle pubsubを接続するためのサンプルコードを使用しています。私の組織はプロキシを使ってインターネットに接続しています。 googleクラウドでプロキシ設定を構成する方法を教えてください。私はHTTP_PROXY env変数を設定しようとしましたが、それでも失敗します。 import json from oauth2client.contrib.gce

    2

    3答えて

    メールボックスでwatch()を呼び出そうとしています。私はサービスのIAMアカウントを設定し、トピックと執筆を作成しました。私は自分のトピックとサブスクリプションに対してサービスアカウントに完全な(所有者)権利を与えました。 )(時計上で実行呼び出すときしかし、私はエラーを取得する:ここで Google.Apis.Requests.RequestError Error sending test

    2

    1答えて

    たとえばAmazonのSQSを使用している場合、X再試行後に削除できなかったメッセージ(ack'd)が別の処理のためにルーティングされるデッドレターキュー(DLQ)を定義できますが、Google Cloud Platform私はこのことについて一切言及していません。

    0

    1答えて

    Pub/Sub 'プッシュ'モデルでは、次のようになります。 プッシュエンドポイントでエラーコードが返された場合、メッセージは指数バックオフポリシー(10秒で上限)で最大7日間再試行されます。 リトライ期間の後にメッセージの処理方法を決定する方法はありますか?つまり、それを何らかのエラーキューなどに送りますか?

    0

    1答えて

    サードパーティプロバイダからリアルタイムデータを取得し、変換してWebSocket経由でブラウザに送る必要があります。 ブラウザから取得するまでに、データを受信して​​から200ms以上かかることはありません。 私は、websocketサーバーが購読してメッセージをブラウザにプッシュするpub/subへのデータフローにpub/subを使用することを考えています。 このアプローチは正しいですか、デー

    0

    2答えて

    Google PubSubからメッセージを引き続き取得しています。メッセージを取得するのにかかる時間が約12〜15秒で、私たちの場合には受け入れられないことを除いて、すべてうまくいっています。以下の私のCallTimingの設定です: public CallSettings GetPullSetting() { CallTiming timing = CallTiming.F