Ditto.asByteBuffer(bytePayload) выдает исключение
В контексте отображения eclipse-ditto я поместил следующий входящий скрипт:
function mapToDittoProtocolMsg(headers, textPayload, bytePayload, contentType) {
switch (contentType) {
case "application/json":
var jsonData = JSON.parse(textPayload);
var temperature = jsonData.temp;
var humidity = jsonData.hum;
var path;
var value;
if (temperature != null && humidity != null) {
path = "/features";
value = {
temperature: {
properties: {
value: temperature
}
},
humidity: {
properties: {
value: humidity
}
}
};
} else if (temperature != null) {
path = "/features/temperature/properties/value";
value = temperature;
} else if (humidity != null) {
path = "/features/humidity/properties/value";
value = humidity;
}
if (!path || !value) {
return null;
}
return Ditto.buildDittoProtocolMsg("tenant_aloxy", headers["device_id"], "things", "twin", "commands", "modify", path, headers, value);
break;
case "application/octet-stream":
let byteBuf = Ditto.asByteBuffer(bytePayload);
var path = "/features/alp/properties/value";
var value = 21;
return Ditto.buildDittoProtocolMsg("tenant_aloxy", headers["device_id"], "things", "twin", "commands", "modify", path, headers, value);
default:
return null;
}
}
Когда я посылаю двоичные данные, я ожидаю второй случай переключения, как и ожидалось. Однако, когда он пытается преобразовать входящие данные как байтовый буфер (Ditto.asByteBuffer(bytePayload);), он выдает следующее исключение:
ReferenceError: "dcodeIO" не определено.
1 ответ
Эта вспомогательная функция в области "Ditto" требует библиотеки "ByteBuffer.js", как описано в документации: https://www.eclipse.org/ditto/connectivity-mapping.html (dcodeIO
был использован как область для этой библиотеки).
Это означает, что вы просто должны разрешить загрузку этой библиотеки в конфигурации вашего отображения: https://www.eclipse.org/ditto/connectivity-mapping.html
{
"incomingScript": "...",
"outgoingScript": "...",
"loadBytebufferJS": true,
"loadLongJS": true
}
После этого вы сможете использовать Ditto.asByteBuffer()