Texto copiado

Google Pubsubes uno de los principales motores Queue usados cobro datos de la editorial oMQTTAplicación para mejores análisis de datos. IntegraciónBevywise MQTT Brokercon Google Pubsub le ayuda a empujar datos de su IoT Dispositivos de borde IIoT a través de MQTT Broker a google pubsub.

Configurar Google Compute para Pubsub

Google Pubsub es accesible desde su cuenta de servicios en la nube de Google. Puedes seguir elDocumento Google Pubsubcrear Google Pubsub con un publicar Tema.


Crear Instance Ubuntu

Vamos a correrBevywise MQTT Brokeren el caso Ubuntu que fue creado en Google Cloud. Referirse al Google help document forcrear el Ubuntu ejemplodentro nube de Google.

Instalación Google Pub/Sub dependencias


Una vez creado una instancia Ubuntu, accede a esa instancia e instala las dependencias siguientes.


  • Abrir terminal e instalar debajo de paquetes de nube de gloud
  • sudo pip install google-cloud-core
  • sudo pip install google-api-core
  • sudo pip install –upgrade google-cloud-pubsub

  • Vaya a la carpeta “/usr/local/lib/python2.7/dist-packages/PyInstaller/hooks/”.

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


  • En ese plegado, abra el archivo “hook-google.cloud.py”

sudo vim hook-google.cloud.py


  • En ese archivo, eliminar todas las líneas predeterminadas y añadir el siguiente código

de PyInstaller.utils.hooksimport copy_metadata
data = copy_metadata(‘google-cloud-core’)
datos += copy_metadata(‘google-api-core’)
datos += copy_metadata(‘google-cloud-pubsub’)

  • Guardar y salir archivo

MQTT Broker Google Pubsub Integration

  • Instala Bevywise MQTTBrokeren la instancia Ubuntu creada.
  • Después de la instalación, vaya a la carpeta Bevywise/MQTT Broker/extension.
  • En esa carpeta, abra “custom_store.py” y reemplace el siguiente código

o
importadores
Admisión json
de Google. importación de energía pubsub_v1
sys.path.append(os.getcwd()+’/lib’)
sys.path.append(‘/usr/local/lib/python2.7/dist-packages’)
project_ Id = ‘project_name ’
broker_ Id = 'testing ’
def handle_Received_Payload(data):
global pubsub_v1
proyecto global_ Id
global broker_ Id
editor = pubsub_v1.PublisherClient()
topic_path = editor.topic_path(project_Id, ‘broker’)
datos = json.dumps(data)
data = data.encode(‘utf-8’)
editor.publish(topic_path, data=data, device=broker_ Id)

  • En este código, “proyecto id” representa el proyecto id que mientras creas google pubsub
  • Guardar y salir del archivo
  • Vaya a Bevywise/MQTT carpeta Broker/conf
  • Abrir “data_store.conf” y cambiar los siguientes parámetros

CUSTOMSTORAGE = ENABLED


  • Guardar y salir del archivo

Si quieres dirigir el MQTTBroker conautenticación, entonces siga los pasos


  • Abrir carpeta Bevywise/MQTTBroker/conf
  • En ese archivo abierto “broker.conf” y cambiar

AUTHENTICATION_ENABLED = Sí


  • Guardar y salir del archivo.
  • Google Pubsub utiliza la autenticación grpc, por lo que debemos exportar el grpc ssl ruta de certificado en el “/etc/environment” para establecer el camino predeterminado para la raíz de grpc ssl certificado.
  • Vaya a la carpeta /etc y abra el archivo “environment” por

sudo vim environment


  • En ese archivo, pega el siguiente comando y guardarlo.

Exportación GRPC_DEFAULT_SSL_ROOTS_FILE_PATH= "usr/local/lib/python2.7/dist-packages /grpc/_cython/_credentials/roots.pem


  • El siguiente reinicia el caso.
  • Una vez reiniciado la instancia, vaya a la carpeta “Bevywise/MQTT Broker/bin”
  • Next start the Bevywise MQTTBroker by

Sudo Sh Runbroker. #


Ahora Bevywise MQTTBroker recopila los datos de su dispositivo de borde y envía al Google pub/sub a través deTienda personalizada. Desde Google Pub/Sub, puede conectar y enviar los datos a su herramienta de análisis de datos.


Inicie sus análisis de datos probando nuestro corredor de MQTT a bajo costo GRATIS.