テキストコピッド

サイトマップQueue の主要エンジンの1つです。 収集する データデータ 出版社から またはMQTTの特長より良いデータ分析のためのアプリケーション。 インテグレーションBevywise MQTT(ビービービーワイワイズ MQTT) ブローカーグーグルパブサブ IoT からデータをプッシュするのに役立ちます。 MQTTブローカーを介してIIoTエッジデバイスをGoogle pubsubに。

パブサブのGoogle Computeを設定する

Google PubsubはGoogleクラウドサービスアカウントからアクセス可能です。 あなたはフォローすることができますGoogle Pubsubドキュメントグーグルパブサブを作成する 出版情報 トピック。


Ubuntuのインスタンスを作成する

運営するBevywise MQTT(ビービービーワイワイズ MQTT) ブローカーUbuntu インスタンスで、 Google Cloudで作成しました。 参照して下さい GoogleヘルプドキュメントUbuntuの作成 インスタンスお問い合わせ Googleクラウド。

インストール Googleパブ/サブの依存関係


Ubuntu インスタンスを作成したら、そのインスタンスにログインし、以下の依存関係をインストールします。


  • ターミナルを開き、gloudクラウドパッケージの下にインストールします
  • sudo pip install グーグルクラウドコア
  • sudo pip インストール google-api-core
  • sudo pip install – google-cloud-pubsub をアップグレード

  • "/usr/local/lib/python2.7/dist-packages/PyInstaller/hooks/" フォルダに移動します。

カートン /usr/local/lib/python2.7/dist-packages/PyInstaller/hooks/


  • そのフォルダ内で、「hook-google.cloud.py」ファイルを開く

sudo vim hook-google.cloud.py - アダルトアフィリエイトプログラム モデルログイン


  • そのファイルでは、すべてのデフォルト行を削除し、以下のコードを追加します。

から PyInstaller.utils.hooksインポートcopy_metadata
data=copy_metadata('google-cloud-core')
データ += copy_metadata('google-api-core')
データ += copy_metadata('google-cloud-pubsub')

  • ファイル保存と終了

MQTTブローカーGoogle Pubsubの統合

  • Bevywise をインストールする MQTTブロカー作成した Ubuntu インスタンス。
  • インストール後、Bevywise/MQTTブローカー/拡張フォルダに移動します。
  • そのフォルダに「custom_store.py」を開き、以下のコードを置き換えます。

輸入のos
インポート sys
インポート json
グーグルから。 クラウドインポート pubsub_v1
sys.path.append(os.getcwd()+ '/lib')
sys.path.append('/usr/local/lib/python2.7/dist-packages')
プロジェクト Id = 'project_name' の一覧 . .
ブローカー_ Id = 「テスト」 . .
def handle_Received_Payload(データ):
グローバルパブサブ_v1
グローバルプロジェクト ログイン
グローバルブローカー_ ログイン
出版社 = pubsub_v1.PublisherClient()
Topics_path=パブリッシャー.topic_path(project_Id, ‘broker’)
data = json.dumps(データ)
データ = data.encode('utf-8')
パブリッシャー.publish(topic_path, data=data, device=broker_Id)

  • このコードでは、Google pubsub の作成中にプロジェクト ID を表す
  • ファイルの保存と終了
  • Bevywise/MQTT に行く ブローカー/confフォルダ
  • 「data_store.conf」を開き、次のパラメーターを変更します。

お客様の声


  • ファイルの保存と終了

MQTTBrokerを実行したい場合認証, その後、手順に従う


  • Bevywise/MQTTBroker/confフォルダを開く
  • 「broker.conf」ファイルを開くと変更

AUTHENTICATION_ENABLED = はい


  • ファイルを保存して終了します。
  • Google Pubsubはgrpcの認証を使用するので、エクスポートする必要があります grpc ssl の証明書パスを “/etc/environment” に設定し、 grpc ssl のルートのデフォルトパスを設定します。 証明書。
  • /etcフォルダに移動し、「環境」ファイルを開く

sudo vim 環境


  • そのファイルでは、以下のコマンドを貼り付けて保存します。

エクスポート GRPC_DEFAULT_SSL_ROOTS_FILE_PATH="usr/local/lib/python2.7/dist-packages /grpc/_cython/_credentials/roots.pem


  • 次にインスタンスを再起動しました。
  • インスタンスを再起動したら、「Bevywise/MQTT Broker/bin」フォルダに移動します
  • 次に、Bevywise MQTTBrokerを起動します

sudo sh runbroker. ログイン


Bevywise MQTTBrokerは、エッジデバイスからデータを収集し、Google pub/subを経由して送信しますカスタムストアお問い合わせ Google Pub/Sub から、データをデータ分析ツールに取り込み、送信することができます。


無料でMQTTブローカーを試して、データ分析を開始しましょう。