Einfaches Beispiel, wie Sie ein AWS IOT-Thema auf einem Raspberry Pi erhalten

Question

Ich bin auf der Suche nach einem einfachen JavaScript-Beispiel, wie Sie Nachrichten von einem Thema erhalten. Ich versuche, einen Build-Cop mit CodeBuild, Lambda, SNS und schließlich IoT zu erstellen. Ich habe erfolgreich Nachrichten zu dem Thema veröffentlicht, aber ich kann nicht für das Leben von mir herausfinden, was zu tun ist, um die Nachricht zu erhalten.

Die Beispiele im SDK sind nicht gut dokumentiert (zumindest für mich) und ich kann nicht herausfinden, welchen Import zu verwenden oder warum und wie man ein einfaches Thema abonnieren kann.

Der Code zu senden die Nachricht an die Sache ist das Folgende. Ich schicke es von einem Lambda. Der Code ist in TypeScript geschrieben, aber ich kopiere und kopiere das transpilierte JavaScript in die Konsole, da TypeScript nativ nicht unterstützt wird.

const params = { 
    topic: 'topic/buildcop', 
    payload: color, 
    qos: 1 
}; 


this.iotdata.publish(params, function(err, data){ 
    if(err){ 
    console.log(`error: ${err}`); 
    } 
    else{ 
    console.log("success?"); 
    //context.succeed(event); 
    } 
}); 

Answer 1

Ich bin mir nicht sicher, ob dies ist, was Sie wollen, aber hier ist ein Beispiel, wie man ein Thema mit der Javascript-sdk abonnieren:

var awsIot = require('aws-iot-device-sdk'); 

// 
// Replace the values of '<YourUniqueClientIdentifier>' and '<YourCustomEndpoint>' 
// with a unique client identifier and custom host endpoint provided in AWS IoT. 
// NOTE: client identifiers must be unique within your AWS account; if a client attempts 
// to connect with a client identifier which is already in use, the existing 
// connection will be terminated. 
// 
var device = awsIot.device({ 
    keyPath: <YourPrivateKeyPath>, 
    certPath: <YourCertificatePath>, 
    caPath: <YourRootCACertificatePath>, 
    clientId: <YourUniqueClientIdentifier>, 
     host: <YourCustomEndpoint> 
}); 

// 
// Device is an instance returned by mqtt.Client(), see mqtt.js for full 
// documentation. 
// 
device 
    .on('connect', function() { 
    console.log('connect'); 
    device.subscribe('topic_1'); 
    device.publish('topic_2', JSON.stringify({ test_data: 1})); 
    }); 

device 
    .on('message', function(topic, payload) { 
    console.log('message', topic, payload.toString()); 
    }); 

Sie können weitere Beispiele sehen an hier : https://github.com/aws/aws-iot-device-sdk-js#jobs