다음 코드는 mqtt를 사용하여 지정된 URL에 json 데이터를 게시하는 코드입니다. http에서 초기 데이터를 검색합니다. 다음node.js를 사용하여 실시간 json 데이터에서 특정 필드를 추출하여 새 단일 json 객체를 만들 수 있습니까?
는var request = require('request');
var JSONStream = require('JSONStream');
var es = require('event-stream');
var mqtt = require('mqtt');
request({url: 'http://isaacs.couchone.com/registry/_all_docs'})
.pipe(JSONStream.parse('rows.*'))
.pipe(es.mapSync(function (data) {
console.info(data);
var client = mqtt.createClient(1883, 'localhost');
client.publish('NewTopic', JSON.stringify(data));
client.end();
return data;
}))
내가 지정한 URL에있는 모든 JSON 데이터를 얻을, 위의 코드에서 MQTT
var mqtt = require('mqtt');
var client = mqtt.createClient();
client.subscribe('NewTopic');
client.on('message', function(topic, message) {
console.info(message);
});
를 통해 (위의 코드에서) 게시 된 데이터를 구독 가입자 코드 수신 된 데이터에서 'id'와 'value'를 추출하여 단일 JSON 객체로 만들고이를 mqtt에 게시하여 다른 클라이언트가 'id'와 'value'만 구독 할 수 있도록해야합니다. '을 json 데이터로 사용합니다.
을 내가 할 수있는 방법 새로운 단일 json 객체로서의이 id와 value? – user3599