タグ

pubsubに関するanimistのブックマーク (3)

  • ゲスト投稿 : MQTT と Cloud Pub/Sub で IoT アプリケーションを構築 | Google Cloud 公式ブログ

    編集部注 : 今回は、Google Cloud Premier Partner である Agosto の投稿を紹介します。同社は 2012 年以降、IoT アプリケーションを含む製品やサービスを Google Cloud PlatformGCP)上で構築、提供しています。この投稿では、同社が開発した Google Cloud Pub/Sub 用の MQTT サービス ブローカと、それを IoT アプリケーションに組み込む方法について説明します。 IoT(Internet of Things : モノのインターネット)は、私たち Agosto の主要事業の 1 つです。私たちは、GCP のさまざまなコンポーネントを利用して、お客様がアイデアを速やかに製品化できるようにお手伝いをしています。 これまで私たちは複数の IoT プラットフォームを評価しましたが、ライセンスが高価でクローズド ソー

    ゲスト投稿 : MQTT と Cloud Pub/Sub で IoT アプリケーションを構築 | Google Cloud 公式ブログ
  • Pub/Sub とは  |  Pub/Sub Documentation  |  Google Cloud

    フィードバックを送信 Pub/Sub とは コレクションでコンテンツを整理 必要に応じて、コンテンツの保存と分類を行います。 Pub/Sub は、メッセージを生成するサービスを、それらのメッセージを処理するサービスと切り離す、非同期のスケーラブルなメッセージング サービスです。 Pub/Sub を使用すると、サービスが 100 ミリ秒程度のレイテンシで非同期に通信できます。 Pub/Sub は、ストリーミング分析と、データを読み込んで配布するためのデータ統合パイプラインに使用されます。これは、サービスの統合を目的としたメッセージング指向のミドルウェア、または、タスクを同時に読み込むキューとしても使用されます。 Pub/Sub を使用すると、イベント プロデューサー(パブリッシャー)とコンシューマー(サブスクライバー)のシステムを作成できます。パブリッシャーは、同期リモート プロシージャ コ

    Pub/Sub とは  |  Pub/Sub Documentation  |  Google Cloud
  • Google Cloud Pub/SubのPythonクライアントがメモリリークするので調査して解決? - GAミント至上主義

    要約 Google Pub/Subクライアントを使い、ずっと動かし続けてたらメモリリークが見つかった 調査したらクライアント自体のバグか仕様だった。そもそも動かし続けるように作られてない multiprocessingのProcessを使い、別プロセスで動かし、メッセージを一定数ごと受け取ったらそのプロセスごと再起動するようにした oceanusのpubsubからデータを受け取り処理を行うrevelationで、pubusbをRedisからGoogle Cloud Pub/Subにしたところ、メモリリークが発生した。 データはbizoceanのイベントログが送られてきて、一つ数KB、~10メッセージ/秒が来る。 起動時は50MBだけど1時間に数MB増え、1週間で数百MBになり、他のPODにも影響してしまう。 番のKubernetes(GKE)では下記コマンドでメモリの増加を確認。 % k

    Google Cloud Pub/SubのPythonクライアントがメモリリークするので調査して解決? - GAミント至上主義
  • 1