如何通过 IoT Agent for JSON 将实际（硬件）物联网设备连接到 FIWARE Orion Context

Question

是否有任何教程或指南可以通过JSON的IoT代理遵循并连接硬件IoT设备？所有教程在虚拟配置设备上都可以正常工作，但是没有关于如何进行和连接实际设备的引用。

我已经尝试了教程（ https://github.com/fiware/tutorials.iots.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-s.iot-coment- Agent-json ）成功，但我不知道如何连接，让我们说一个实际的智能灯。

Answer 1

本教程应用程序创建能够通过 HTTP 或 MQTT 发送有效负载的虚拟设备。

// measures sent over HTTP are POST requests with params
sendAsHTTP(deviceId, state) {
    const options = {
        method: 'POST',
        url: IOT_AGENT_URL,
        qs: { k: getAPIKey(deviceId), i: deviceId },
        headers: this.headers,
        body: state
    };
    const debugText = 'POST ' + IOT_AGENT_URL + '?i=' + options.qs.i + '&k=' + options.qs.k;

    request(options, (error) => {
        if (error) {
            debug(debugText + ' ' + error.code);
        }
    });
    SOCKET_IO.emit('http', debugText + '  ' + state);
}

// measures sent over MQTT are posted as topics 
sendAsMQTT(deviceId, state) {
    let topic = '/' + getAPIKey(deviceId) + '/' + deviceId + '/attrs';
    if (process.env.MQTT_TOPIC_PROTOCOL !== '') {
        topic = '/' + MQTT_TOPIC_PROTOCOL + topic;
    }
    MQTT_CLIENT.publish(topic, state);
}

任何真实设备也需要遵循这些步骤，例如查看 Arduino 文档 您可以对设备进行编程，使其在选定的 MQTT 主题上发出信号。

相同的技术可用于致动。要么让设备侦听 HTTP：

if (DEVICE_TRANSPORT === 'HTTP') {
    debug('Listening on HTTP endpoints: /iot/bell, /iot/door, iot/lamp');

    const iotRouter = express.Router();

    // The router listening on the IoT port is responding to commands going southbound only.
    // Therefore we need a route for each actuator
    iotRouter.post('/iot/bell:id', Southbound.bellHttpCommand);
    iotRouter.post('/iot/door:id', Southbound.doorHttpCommand);
    iotRouter.post('/iot/lamp:id', Southbound.lampHttpCommand);
    iotRouter.post('/iot/robot:id', Southbound.robotHttpCommand);
    // Dummy ISOBUS/ISOXML endpoint.
    iotRouter.post('/iot/isoxml', Southbound.isobusHttpCommand);

    iot.use('/', iotRouter);
}

要么订阅给定的 MQTT 主题：

if (DEVICE_TRANSPORT === 'MQTT') {
    const apiKeys = process.env.DUMMY_DEVICES_API_KEYS || process.env.DUMMY_DEVICES_API_KEY || '1234';

    MQTT_CLIENT.on('connect', () => {
        apiKeys.split(',').forEach((apiKey) => {
            let topic = '/' + apiKey + '/#';
            if (process.env.MQTT_TOPIC_PROTOCOL !== '') {
                topic = '/' + MQTT_TOPIC_PROTOCOL + topic;
            }
            debug('Subscribing to MQTT Broker: ' + MQTT_BROKER_URL + ' ' + topic);
            MQTT_CLIENT.subscribe(topic);
            MQTT_CLIENT.subscribe(topic + '/#');
        });
    });

    mqtt.connect(MQTT_BROKER_URL);

    MQTT_CLIENT.on('message', function (topic, message) {
        // message is a buffer. The IoT devices will be listening and
        // responding to commands going southbound.
        debug('MQTT message received on', topic.toString());
        Southbound.processMqttMessage(topic.toString(), message.toString());
    });
}

当然，此示例适用于 JSON 或 Ultralight 有效负载，其他协议需要连接到适当的中间件（例如连接到 OPC-UA 的 OPC-UA 设备） UA 服务器），但是一般来说，您的设备将能够下载适当的通信库，并且您需要使用设备本身上找到的语言对设置进行编码并测量速率和/或驱动响应 - Arduino 文档正在使用 C++ 例子。