Text geknüpft

Google Pubsubist einer der führenden Queue-Engine, die sammeln Daten aus dem Verlag oderMQTAnwendung für eine bessere Datenanalyse. IntegrationBevywise MQTT Brokermit Google Pubsub hilft Ihnen, Daten von Ihrem IoT & IIoT Randgeräte über MQTT Broker zu google pubsub.

Google Compute für Pubsub einrichten

Google Pubsub ist von Ihrem Google-Cloud-Service-Konto aus erreichbar. Sie können derGoogle Pubsub DokumentGoogle Pubsub mit einem Veröffentlichung Thema.


Ubuntu instance

Wir werden dieBevywise MQTT Brokerauf der Ubuntu-Instanz, die erstellt in Google Cloud. Refer Google Hilfe Dokument fürDie Welt der Welt Beispielin Google Cloud.

Installation Google Pub/Sub Abhängigkeiten


Sobald Sie eine Ubuntu-Instanz erstellt haben, melden Sie sich an diese Instanz und installieren Sie die folgenden Abhängigkeiten.


  • Öffnen Sie Terminal und installieren Sie unten gloud Cloud-Pakete
  • sudo pip install google-cloud-core
  • sudo pip install google-api-core
  • sudo pip install –upgrade google-cloud-pubsub

  • Gehen Sie zu „/usr/local/lib/python2.7/dist-packages/PyInstaller/hooks/“ Ordner.

c) /usr/local/lib/python2.7/dist-packages/PyInstaller/hooks/


  • In diesem Falter, öffnen Sie “hook-google.cloud.py” Datei von

sudo vim hook-google.cloud.py


  • In dieser Datei entfernen Sie alle Standardzeilen und fügen Sie den folgenden Code hinzu

von PyInstaller.utils.hooksImport copy_metadata
Daten = copy_metadata(„google-cloud-core“)
Daten += copy_metadata(„google-api-core“)
Daten += copy_metadata(„google-cloud-pubsub“)

  • Datei speichern und beenden

MQTT Broker Google Pubsub Integration

  • Bevywise herunterladen MQTTBrokerin der erstellten Ubuntu-Instanz.
  • Nach der Installation, gehen Sie zu Bevywise/MQTT Broker/Erweiterung Ordner.
  • In diesem Ordner öffnen Sie “custom_store.py” und ersetzen Sie den folgenden Code

Einfuhr
Einfuhr sys
Import json
von google. Cloud-Import pubsub_v1
sys.path.append(os.getcwd()+’/lib)
sys.path.append(‚/usr/local/lib/python2.7/dist-packages‘)
Projekt: Id = „Projekt_Name „
Broker Id = „Prüfung“
def handle_Received_Payload(data):
Global pubsub_v1
Globales Projekt_ ich
Global broker_ ich
Verlag = pubsub_v1.PublisherClient()
top_path = puber.topic_path(project_Id, ‚broker‘)
Daten = json.dumps(data)
Daten = data.encode(„utf-8“)
puber.publish(topic_path, data=data, device=broker_Id)

  • In diesem Code stellen “Projekt id” die Projekt-ID dar, die Sie beim Erstellen von Google pubsub
  • Speichern und beenden Sie die Datei
  • Gehe zu Bevywise/MQTT Broker/conf Ordner
  • Öffnen Sie “data_store.conf” und ändern Sie die folgenden Parameter

ZOLLE = ENABLED


  • Speichern und beenden Sie die Datei

Wenn Sie den MQTTBroker mitAuthentisierung, dann den Schritten folgen


  • Bevywise/MQTTBroker/conf Ordner öffnen
  • In diesem Öffnen Sie die Datei „broker.conf“ und ändern

AUTHENTIC_ENABLED = JA


  • Speichern und die Datei verlassen.
  • Google Pubsub verwendet grpc-Authentifizierung, so müssen wir exportieren die grpc ssl Certificate path in the “/etc/environment” um den Standardpfad für grpc ssl root einzustellen Zertifikat.
  • Gehen Sie zum Ordner /etc und öffnen Sie die Datei „Umwelt“ von

wohnzimmer Umwelt


  • In dieser Datei fügen Sie den folgenden Befehl ein und speichern Sie ihn.

Ausfuhr GRPC_DEFAULT_SSL_ROOTS_FILE_PATH=“usr/local/lib/python2.7/dist-Pakete /grpc/_cython/_credentials/roots.pem“


  • Als nächstes wurde die Instanz neu gestartet.
  • Sobald Sie die Instanz neu gestartet haben, gehen Sie in den Ordner „Bevywise/MQTT Broker/bin“
  • Nächster Start der Bevywise MQTTBroker von

!


Jetzt sammelt Bevywise MQTTBroker die Daten von Ihrem Endgerät und sendet überIn den Warenkorb. Von Google Pub/Sub können Sie die Daten an Ihr Datenanalysetool anschließen und senden.


Starten Sie Ihre Datenanalysen, indem Sie unseren MQTT Broker kostenlos ausprobieren.