google-cloud-pubsub

0熱

1答えて

Firebaseドキュメントには、pubSubトピックの簡単な購読方法が記載されています。んクラウド機能やFirebase管理SDKは、PubSubのイベントを公開するための方法を提供したり、我々は、Googleクラウドプラットフォームのドキュメントに記載されているものに限定されていますhttps://cloud.google.com/pubsub/docs/publisher#pubsub-p

2熱

2答えて

AttributeErrorを修正する方法：Google Cloud Interactive ShellでPythonを実行すると、 'module'オブジェクトに 'Client'属性がありません

トラフィックセンサーがリアルタイムでGoogleのPubSubにデータを送信するシミュレーションを実行しようとしていますクラウドシェル。私はこのエラーgoogle.cloud.pubsub.__file__を実行しようとしました Traceback (most recent call last): File "./send_sensor_data.py", line 87, in <mo

0熱

1答えて

Google PubSubはPython APIの同期プルをサポートしていますか？

私が読んだドキュメンテーションは、非同期プルだけをカバーしています。これがPython APIの唯一のオプションであることを確認したいと思います。

0熱

1答えて

Apache Beam Dataflow： 'NoneType'オブジェクトには 'parts'属性がありません

私はパイプラインを作成してpubsubからストリームを読み込み、apache beamでgoogle cloudデータフローを使用してbigqueryに書き込みます。私はこのコードを持っている： import apache_beam as beam from apache_beam.transforms.window import FixedWindows topic = 'project

0熱

1答えて

バッチを使用してDataFlowでPubSubから読み取る方法

PubsubソースのSDK 1.9.1にはPubsubIO.Read.maxReadTimeとPubsubIO.Read.maxNumRecordsのメソッドがあります。これらのメソッドは、pubsubメッセージからバインドされたコレクションを作成することを許可し、バッチモードでDataflowパイプラインを開始することができました。 Dataflow SDK 2.1を使用して、どのようにsimi

0熱

1答えて

Google Cloud Pub/Subノードライブラリの解析エラー

ノードクライアントライブラリを使用してGoogle Cloud Pub/Sub apiから返されたエラー応答を処理しようとしています。あなたが直接彼らのREST APIを使用している場合、私は、見ることができるものから、（。すなわちないクライアントライブラリを介して）彼らは一般的なHTTPエラーコードを返す： https://cloud.google.com/pubsub/docs/referen

0熱

1答えて

各パブ/サブトピックに独自の接続GCPが必要ですか？

データを追跡するためにpub/subを使用します。パブのサブには600以上のトピックがあります。私たちの開発者は、各トピックはGCPへの専用接続を必要とするため、アプリケーションはトピック数に等しい追加のファイル記述子を必要とすると述べています。これは正しいです？私はこれを言及したパブ/サブ文書を見つけることができません。ありがとうございました。

1熱

2答えて

Google PubSubメッセージの複製

私はpythonクライアント（これはgoogle-cloud 0.30.0の一部として提供されます）を使ってメッセージを処理しています。私のメッセージが（約10％）重複していることがあります。数時間以内に同じメッセージを何度も何度も何度も50のインスタンスに送信します。サブスクリプションの設定は600秒のアック時間ですが、メッセージは前のバージョンの1分後に再送信されることがあります。実行中

0熱

1答えて

はPython SDKのためにpubsubをインポートできませんappengine/psutil

私はpubsubとGoogle App Engineで作業していますが、pubsub_v1をインポートしようとするとpsutilに関する問題が発生しています。私は別にそれを実行したとき PubSubのは素晴らしい仕事をしているが、私はアプリエンジンのdev_appserverを使用する場合、私はこのトレースバックを得た：pubsubには、CPUの動作を監視しようとすると、それはpsutilで失敗し

0熱

1答えて

PubSub経由でメッセージを送信し、将来の日付で受信する方法

私は春のブートプロジェクトでPubSubを使い始めています。PubSubを使ってこれが可能かどうかわからない機能を実装する予定です。トピックにメッセージを公開する必要があり、サブスクライバはすぐにメッセージを受信する必要はありません。サブスクライバは5日以内にメッセージを受信する必要があります（将来の任意の日付）。これが可能かどうかわかりませんが、ドキュメントで何も見つかりませんでした。これが