var MQTT = exigem ( 'MQTT'); que mostra erro de sintaxe

votos
-1

Estou seguindo este tutorial dados poupança regardign ao banco de dados usando MQTT para mysql sensor para mysql via MQTT onde estou na parte app_mqtt.js onde eu tentar seguir exatamente a mesma coisa para criar o arquivo js, mas quando eu tentar executá-lo via python, ele mostra um erro de:

File app_mqtt.js, line 1
var mqtt = require('mqtt'); 
   ^
SyntaxError: invalid syntax

Eu já tenho o MQTT via npm i mqtte npm install mqtt --save, no entanto, ainda tem um tal erro, eu realmente preciso de ajuda neste. Obrigado.

var mqtt = require('mqtt');

var Topic = '#'; //subscribe to all topics

var Broker_URL = 'mqtt://192.168.1.123';

var options = {
    clientId: 'MyMQTT',
    port: 1883,
    keepalive : 60
};

var client  = mqtt.connect(Broker_URL, options);
client.on('connect', mqtt_connect);
client.on('reconnect', mqtt_reconnect);
client.on('error', mqtt_error);
client.on('message', mqtt_messsageReceived);
client.on('close', mqtt_close);

function mqtt_connect()
{
    console.log(Connecting MQTT);
    client.subscribe(Topic, mqtt_subscribe);
}

function mqtt_subscribe(err, granted)
{
    console.log(Subscribed to  + Topic);
    if (err) {console.log(err);}
}

function mqtt_reconnect(err)
{
    console.log(Reconnect MQTT);
    if (err) {console.log(err);}
    client  = mqtt.connect(Broker_URL, options);
}

function mqtt_error(err)
{
    console.log(Error!);
    if (err) {console.log(err);}
}

function after_publish()
{
    //do nothing
}

function mqtt_messsageReceived(topic, message, packet)
{
    console.log('Topic=' +  topic + '  Message=' + message);
}

function mqtt_close()
{
    console.log(Close MQTT);
}
Publicado 08/11/2018 em 06:38
fonte usuário
Em outras línguas...                            


1 respostas

votos
0

De acordo com seu código, ele mostra muito bem.

1) Tente reiniciar o servidor.

2) verificar o seu código para este código

npm i mqtt --save

var mqtt = require('mqtt')
var client  = mqtt.connect('mqtt://{Your connection string}')

client.on('connect', function () {
  client.subscribe('presence', function (err) {
    if (!err) {
      client.publish('presence', 'Hello mqtt')
    }
  })
})

client.on('message', function (topic, message) {
 // message is Buffer
 console.log(message.toString())
 client.end()
})

3) Por fim, re-instalar o pacote.

Nota: Se ainda emitir, por favor, compartilhe seu código. Então eu posso depurá-lo.

Respondeu 08/11/2018 em 07:47
fonte usuário

Cookies help us deliver our services. By using our services, you agree to our use of cookies. Learn more